kafka使用ssl验证时，控制台生产者，消费者无法正常运行

用命令行perducer和consumer,jps可以看到生产者消费者的进程信息，但是用生产者输入信息时就报错，ssl验证是可以看到服务器证书。
报错信息：

[2017-08-10 19:38:00,181] WARN Failed to send SSL Close message  (org.apache.kafka.common.network.SslTransportLayer)
java.io.IOException: Broken pipe
        at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
        at sun.nio.ch.IOUtil.write(IOUtil.java:65)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471)
        at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:195)
        at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:163)
        at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:690)
        at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:47)
        at org.apache.kafka.common.network.Selector.close(Selector.java:487)
        at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:368)
        at org.apache.kafka.common.network.Selector.poll(Selector.java:291)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)
        at java.lang.Thread.run(Thread.java:745)

哥们你这ssl有问题那。

回答于 7年前

半兽人

太随意 -> 半兽人 7年前

但是我通过openssl s_client -debug -connect localhost:9093 -tls1验证的时候有证书信息呀，自己建立的ssh文件也都是按文档配置的

半兽人 -> 太随意 7年前

你的生产者和消费者命令怎么打的。

kafka-console-consumer.sh --bootstrap-server kafka2:9093 --topic test --consumer.config /usr/local/ssl/producer.properties
kafka-console-producer.sh --broker-list kafka1:9093 --topic test --producer.config /usr/local/ssl/producer.properties

太随意 -> 太随意 7年前

其中ssl下的producer.properties是我照着别的文档重新建立的文件，配置了ssl的相关信息和bootstrap.servers

是按照这个文章来的吗？
https://www.orchome.com/171

之前照你的这篇文档配置的，很多地方没有配置好，后来是照https://blog.csdn.net/jsjsjs1789/article/details/53161985这个博文配置的，但是基本的配置都是差不多的

配置ssl之后，kafka重启过吧，看看kafka中是否存在错误日志。

重启kafka的时候，日志信息 server.properties中没有错误信息

大神，能不能加下你QQ，我截图给你看看我的配置，新人求教 QQ：634749549

我这边办公网络无法登陆QQ，实在不好意思。
logs/server.log

没关系，那您下班了可以加一下我吗？我感觉可能是我配置的问题，想向您多请教一下，论坛这里交流太麻烦了，拜托

好的，按照教程一步一步来，保证版本是新的，这个功能不复杂。多观察。

十分感谢，最近才开始搭建kafka,很多地方还需要学习

你的答案

查看kafka相关的其他问题或提一个您自己的问题。

kafka使用ssl验证时，控制台生产者，消费者无法正常运行

你的答案

昵称