Hi All , Thanks a lot for your help .
A bug has been logged for said issue and can be found at , https://issues.apache.org/jira/browse/KAFKA-5401 Thanks again . On Sun, Jun 4, 2017 at 6:38 PM, Martin Gainty <mgai...@hotmail.com> wrote: > > ________________________________ > 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. >
