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/04 14:39:00 UTC
[jira] [Resolved] (KAFKA-7583) Unable to close kafka producer if
kafka not avaibalbe
[ https://issues.apache.org/jira/browse/KAFKA-7583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Vitalina Horyukova resolved KAFKA-7583.
---------------------------------------
Resolution: Duplicate
> Unable to close kafka producer if kafka not avaibalbe
> -----------------------------------------------------
>
> 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, 1.1.1
> Environment: Linux xxx 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 1.8.0_152
> Reporter: Vitalina Horyukova
> Priority: Major
>
> 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)