kafka使用ssl验证时，控制台生产者，消费者无法正常运行修订版本明细

源

采纳

编辑于

太随意

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

kafka

用命令行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)

预览