kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From IT Consultant <0binarybudd...@gmail.com>
Subject Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe
Date Wed, 07 Jun 2017 18:50:00 GMT
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 <mgainty@hotmail.com> wrote:

>
> ________________________________
> From: IT Consultant <0binarybuddha1@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.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message