kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Patrick Oswald (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-8565) Random IllegalStateException in producer
Date Wed, 19 Jun 2019 09:22:00 GMT
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)

Mime
View raw message