Looking at KAFKA-3702, it is still Open. FYI
On Thu, Mar 15, 2018 at 5:51 PM, Raghav <raghavas...@gmail.com> wrote: > 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 >
