I am hitting this issue possible in 10.2.1. Can someone please confirm if this issue was fixed in 10.2.1 or not ?
R On Wed, Jun 7, 2017 at 11:50 AM, IT Consultant <0binarybudd...@gmail.com> wrote: > 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. > > > -- Raghav
