Patrick Oswald created KAFKA-8565:
-------------------------------------
Summary: Random IllegalStateException in producer
Key: KAFKA-8565
URL: https://issues.apache.org/jira/browse/KAFKA-8565
Project: Kafka
Issue Type: Bug
Affects Versions: 2.2.0
Environment: confluent-consumer 2.12
Cluster with:
* 5 Kafka vms
* 3 Zookeeper vms
* 1 rest-proxy vm
* 1 schema-registry vm
Reporter: Patrick Oswald
While writing into a topic i get an Uncaught Error in kafka producer I/O thread.
{noformat}
[2019-06-19 10:51:40,489] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
{noformat}
The complete output looks like this:
{noformat}
bin/kafka-topics.sh --list --bootstrap-server 172.23.84.155:9092
test
patrick.oswald:10:24
-> ~/kafka/kafka_2.12-2.2.0 $ bin/kafka-console-producer.sh --broker-list
kafka02:9092 --topic test
>message 1
[2019-06-19 10:24:46,690] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
>^[[A^Cpatrick.oswald:10:25
-> ~/kafka/kafka_2.12-2.2.0 $ 130 bin/kafka-console-producer.sh --broker-list
kafka01.services-lpz.rsint.net:9092 --topic test
>message 1
[2019-06-19 10:25:23,799] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
[2019-06-19 10:25:23,828] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
>message
>,message
>^Cpatrick.oswald:10:27
-> ~/kafka/kafka_2.12-2.2.0 $ 130 bin/kafka-console-consumer.sh
--bootstrap-server kafka01:9092 --topic test --from-beginning
message 1
message 1
message
,message
^CProcessed a total of 4 messages
patrick.oswald:10:27
-> ~/kafka/kafka_2.12-2.2.0 $ 130 bin/kafka-console-producer.sh --broker-list
kafka01:9092 --topic test
>test message
[2019-06-19 10:51:40,489] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
[2019-06-19 10:51:40,517] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
[2019-06-19 10:51:40,534] ERROR [Producer clientId=console-producer] Uncaught
error in kafka producer I/O thread:
(org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: No entry found for connection 0
at
org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at
org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:311)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at java.base/java.lang.Thread.run(Thread.java:834)
>^Cpatrick.oswald:10:51
-> ~/kafka/kafka_2.12-2.2.0 $ 130 bin/kafka-console-consumer.sh
--bootstrap-server kafka01:9092 --topic test --from-beginning
message 1
message 1
message
,message
test message
^CProcessed a total of 5 messages
{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
