You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Raghav <ra...@gmail.com> on 2018/03/16 00:51:37 UTC
Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe
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 <0b...@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 <mg...@hotmail.com> wrote:
>
> >
> > ________________________________
> > From: IT Consultant <0b...@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
Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe
Posted by Raghav <ra...@gmail.com>.
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 <yu...@gmail.com> wrote:
> Looking at KAFKA-3702, it is still Open.
>
> FYI
>
> On Thu, Mar 15, 2018 at 5:51 PM, Raghav <ra...@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 <0binarybuddha1@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 <mg...@hotmail.com>
> > wrote:
> > >
> > > >
> > > > ________________________________
> > > > From: IT Consultant <0b...@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
Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe
Posted by Ted Yu <yu...@gmail.com>.
Looking at KAFKA-3702, it is still Open.
FYI
On Thu, Mar 15, 2018 at 5:51 PM, Raghav <ra...@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 <0b...@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 <mg...@hotmail.com>
> wrote:
> >
> > >
> > > ________________________________
> > > From: IT Consultant <0b...@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
>