[jira] [Created] (KAFKA-9054) Kafka client with misconfigured TLS gets stuck in a loop

["Brent Farrell (Jira)" <ji...@apache.org>]

Brent Farrell created KAFKA-9054:
------------------------------------

             Summary: Kafka client with misconfigured TLS gets stuck in a loop
                 Key: KAFKA-9054
                 URL: https://issues.apache.org/jira/browse/KAFKA-9054
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 1.1.0
            Reporter: Brent Farrell


If you configure a Kafka consumer to use a truststore that does not have the certificate that the broker is using a call to poll will get stuck in a loop with and print the message while never returning:

 

org.apache.kafka.common.network.SslTransportLayer Failed to send SSL Close message

java.io.IOException: Broken pipe

                at sun.nio.ch.FileDispatcherImpl.write0(Native Method) ~[?:1.8.0_45]

                at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) ~[?:1.8.0_45]

                at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) ~[?:1.8.0_45]

                at sun.nio.ch.IOUtil.write(IOUtil.java:65) ~[?:1.8.0_45]

                at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471) ~[?:1.8.0_45]

                at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:209) ~[kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:172) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:718) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:61) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.Selector.doClose(Selector.java:746) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.Selector.close(Selector.java:734) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:532) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.common.network.Selector.poll(Selector.java:424) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:460) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:261) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:156) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:228) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:205) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:279) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1149) [kafka-clients-1.1.0.jar:?]

                at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115) [kafka-clients-1.1.0.jar:?]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)