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)
