Is It recommended to move to 1.0 release if we want to overcome this issue ? Please advise, Ted.
Thanks. R On Thu, Mar 15, 2018 at 7:43 PM, Ted Yu <yuzhih...@gmail.com> wrote: > 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 > > > -- Raghav
