Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe

[Martin Gainty]

________________________________
From: IT Consultant <0binarybudd...@gmail.com>
Sent: Friday, June 2, 2017 11:02 AM
To: users@kafka.apache.org
Subject: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe

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)

MG>Here is org.apache.kafka.common.network.SslTransportLayer code:
    /**
    * Flushes the buffer to the network, non blocking
    * @param buf ByteBuffer
    * @return boolean true if the buffer has been emptied out, false otherwise
    * @throws IOException
    */
    private boolean flush(ByteBuffer buf) throws IOException {
        int remaining = buf.remaining();
        if (remaining > 0) {
            int written = socketChannel.write(buf); //no check for isOpen() 
*socketChannel.isOpen()*
            return written >= remaining;
        }
        return true;
    }

MG>it appears upstream monitor *container* closed connection but kafka 
socketChannel never tested (now-closed) connection with isOpen()
MG>i think you found a bug
MG>can you file bug in kafka-jira ?
https://issues.apache.org/jira/browse/KAFKA/?selectedTab=com.atlassian.jira.jira-projects-plugin:summary-panel
Kafka - ASF JIRA - 
issues.apache.org<https://issues.apache.org/jira/browse/KAFKA/?selectedTab=com.atlassian.jira.jira-projects-plugin:summary-panel>
issues.apache.org
Atlassian JIRA Project Management Software (v6.3.15#6346-sha1:dbc023d) About 
JIRA; Report a problem; Powered by a free Atlassian JIRA open source license 
for Apache ...




         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.