卡夫卡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上的消息

回答

相关问题