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.
>

Reply via email to