Unless you're experiencing any connection issues then I would say this is a benign warning message.
Essentially what it's saying here is that the connection was closed (broken pipe) before it (wherever you're getting the log from) was able to send the last close_notify message. When one party decides to close a connection it sends a close_notify message and should wait to receive a close_notify message from the remote side. In many cases, some implementations just go ahead and close a connection upon receiving the a close_notify message and won't bother responding. You can have a look at the following link for more information: https://security.stackexchange.com/questions/82028/ssl-tls-is-a-server-always-required-to-respond-to-a-close-notify On Fri, Jun 2, 2017 at 10:02 AM, IT Consultant <0binarybudd...@gmail.com> wrote: > Hi All, > > I have been seeing below error since three days , > > Can you please help me understand more about this , > > > 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:194) > at > org.apache.kafka.common.network.SslTransportLayer. > close(SslTransportLayer.java:148) > at > org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:45) > at > org.apache.kafka.common.network.Selector.close(Selector.java:442) > at org.apache.kafka.common.network.Selector.poll( > Selector.java:310) > at > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:256) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:216) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:128) > at java.lang.Thread.run(Thread.java:745) > > > Thanks a lot. >
