Hi, I’m using the confluent kafka images and whenever I turn off a broker I get the following messages:
[2017-02-01 02:44:48,310] 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 kafka.utils.NetworkClientBlockingOps$.awaitReady$1(NetworkClientBlockingOps.scala:86) at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:93) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:230) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2017-02-01 02:44:48,310] WARN [Controller-13-to-broker-13-send-thread], Controller 13's connection to broker kafka-13-ap-southeast-2.kafka.mydomain.com:9093 (id: 13 rack: null) was unsuccessful (kafka.controller.RequestSendThread) java.io.IOException: Connection to kafka-13-ap-southeast-2.kafka.mydomain.com:9093 (id: 13 rack: null) failed SSL communication is enabled, and the kafka instances communicate with it so I believe all is configured well on the SSL end. I’m also troubled by rack: null because it is set on boot yet it seems to be forgotten on shutdown? I don’t think these issues are blocking as my kafka broker still shuts down properly, but the log is polluted by all these messages which might hide some other issues Is it a known bug? Regards, Stephane
