You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Vitalina Horyukova (JIRA)" <ji...@apache.org> on 2018/11/01 22:09:00 UTC
[jira] [Created] (KAFKA-7583) Producer force shutdown doesn't work
when all brokers is down.
Vitalina Horyukova created KAFKA-7583:
-----------------------------------------
Summary: Producer force shutdown doesn't work when all brokers is down.
Key: KAFKA-7583
URL: https://issues.apache.org/jira/browse/KAFKA-7583
Project: Kafka
Issue Type: Bug
Components: producer
Affects Versions: 0.11.0.0
Environment: {code}
uname -a
Linux kassa 3.13.0-139-generic #188-Ubuntu SMP Tue Jan 9 14:43:09 UTC 2018 x86_64 x86_64 x86_64 GNU/Linux
java --version
java 1.8.0_152
{code}
Reporter: Vitalina Horyukova
Hi!
When all Kafka brokers are down, thread which called {{KafkaProducer.close}} the infinity stucks in second join to {{KafkaProducer.ioThread}}, because {{KafkaProducer.ioThread}} infinity spins over {{while}} cycle in {{Sender.maybeWaitForProducerId}}. The root cause of this is that {{Sender.awaitLeastLoadedNodeReady}} -> {{NetworkClientUtils.awaitReady}} throws {{IOException}} every iteration.
In logs you can see infinity repeation of this part every `retry.backoff.ms`:
{code:java}
[2018-11-01T16:19:47.583+03:00] TRACE [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Found least loaded node kafka:9093 (id: -1 rack: null)
[2018-11-01T16:19:47.583+03:00] TRACE [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Found least loaded node kafka:9093 (id: -1 rack: null)
[2018-11-01T16:19:47.583+03:00] DEBUG [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Initialize connection to node -1 for sending metadata request
[2018-11-01T16:19:47.583+03:00] DEBUG [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Initiating connection to node -1 at kafka:9093.
[2018-11-01T16:19:47.585+03:00] DEBUG [kafka-producer-network-thread | producer-1] [] [] [] [Selector] Connection with kafka/xxx.xxx.xxx.xxx disconnected
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at org.apache.kafka.common.network.SslTransportLayer.finishConnect(SslTransportLayer.java:109)
at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:95)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:359)
at org.apache.kafka.common.network.Selector.poll(Selector.java:326)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:432)
at org.apache.kafka.clients.NetworkClientUtils.isReady(NetworkClientUtils.java:39)
at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:62)
at org.apache.kafka.clients.producer.internals.Sender.awaitLeastLoadedNodeReady(Sender.java:409)
at org.apache.kafka.clients.producer.internals.Sender.maybeWaitForProducerId(Sender.java:418)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:203)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162)
at java.lang.Thread.run(Thread.java:748)
[2018-11-01T16:19:47.585+03:00] DEBUG [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Node -1 disconnected.
[2018-11-01T16:19:47.585+03:00] WARN [kafka-producer-network-thread | producer-1] [] [] [] [NetworkClient] Connection to node -1 could not be established. Broker may not be available.
[2018-11-01T16:19:47.585+03:00] DEBUG [kafka-producer-network-thread | producer-1] [] [] [] [Sender] Broker {} disconnected while awaiting InitProducerId response
java.io.IOException: Connection to kafka:9093 (id: -1 rack: null) failed.
at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
at org.apache.kafka.clients.producer.internals.Sender.awaitLeastLoadedNodeReady(Sender.java:409)
at org.apache.kafka.clients.producer.internals.Sender.maybeWaitForProducerId(Sender.java:418)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:203)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162)
at java.lang.Thread.run(Thread.java:748)
[2018-11-01T16:19:47.585+03:00] TRACE [kafka-producer-network-thread | producer-1] [] [] [] [Sender] Retry InitProducerIdRequest in 100ms.
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)