卡夫卡Procuder不使用SSL生成SSL上的消息

我正在嘗試將KAFKA與Spring集成，我的JAVA應用程序正在與KAFKA服務器進行通信，並且我還在使用HTTP運行應用程序時收到消息。卡夫卡Procuder不使用SSL生成SSL上的消息

現在我想現在使用Spring卡夫卡添加SSL，我已經做了SSL KAFKA指定的變化和SPRING KAFKA

通信情況正常，當我使用命令行（使用SSL）上運行的生產和消費，但當我更改java應用程序的配置，並嘗試生產和消費的主題消息的消費者工作正常，我得到的消息在指定的主題

但生產者沒有按預期工作消息發送從JAVA應用程序生產者在消費者（niether命令行或JAVA應用程序消費者）上沒有收到

我已經使用它，但沒有找到答案，任何指針？

PS：KAFKA版本卡夫卡0.9.0.0，JAVA 7，並與Spring中使用的SSL性能如下

<prop key="ssl.keystore.location">/keystore.jks</prop> 
<prop key="ssl.keystore.password">password</prop> 
<prop key="ssl.key.password">password</prop> 
<prop key="security.protocol">SSL</prop> 
<prop key="ssl.truststore.location">/truststore.jks</prop> 
<prop key="ssl.truststore.password">password</prop>

來源

2016-03-01 user3185729

請添加該屬性：

ssl.protocol=SSL

這裏是所有的財產需要製片人：

{ 
ssl.protocol=SSL 
security.protocol=SSL 
ssl.truststore.location=/home/vagrant/securityDemo/kafka.client.truststore.jks 
ssl.truststore.password=test1234 
ssl.keystore.location=/home/vagrant/securityDemo/kafka.server.keystore.jks 
ssl.keystore.password=test1234 
ssl.key.password=test1234 
}

參考 - 工作代碼：https://github.com/Symantec/kafka-security-0.9/blob/master/src/main/resources/Producer.Properties

來源

2016-03-20 23:42:19 supermonk

感謝您的答覆，但我正在嘗試使用Spring，我已經在XML中添加了該協議標記，但它沒有幫助。 – user3185729

任何錯誤日誌？從卡夫卡方面？你可以嘗試將Java代碼與下面的代碼進行比較。它爲我工作。 https://github.com/Symantec/kafka-security-0.9/blob/master/src/main/java/com/symantec/cpe/kafka/producer/KafkaProducerNewJava.java – supermonk

卡夫卡Procuder不使用SSL生成SSL上的消息

回答

相關問題