[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821393#comment-16821393 ]
Matthias J. Sax commented on KAFKA-8248: ---------------------------------------- It was reported for `2.0.0` but we assume it affects newer (and even older versions), too. > Producer may fail IllegalStateException > --------------------------------------- > > Key: KAFKA-8248 > URL: https://issues.apache.org/jira/browse/KAFKA-8248 > Project: Kafka > Issue Type: Bug > Components: producer > Affects Versions: 2.0.0 > Reporter: Matthias J. Sax > Assignee: Matthias J. Sax > Priority: Major > > In a Kafka Streams application, we observed the following log from the > producer: > {quote}2019-04-17T01:58:25.898Z 17466081 [kafka-producer-network-thread | > client-id-enrichment-gcoint-StreamThread-7-0_10-producer] ERROR > org.apache.kafka.clients.producer.internals.Sender - [Producer > clientId=client-id-enrichment-gcoint-StreamThread-7-0_10-producer, > transactionalId=application-id-enrichment-gcoint-0_10] Uncaught error in > kafka producer I/O thread: > 2019-04-17T01:58:25.898Z java.lang.IllegalStateException: Attempt to send a > request to node 1 which is not ready. > 2019-04-17T01:58:25.898Z at > org.apache.kafka.clients.NetworkClient.doSend(NetworkClient.java:430) > 2019-04-17T01:58:25.898Z at > org.apache.kafka.clients.NetworkClient.send(NetworkClient.java:411) > 2019-04-17T01:58:25.898Z at > org.apache.kafka.clients.producer.internals.Sender.maybeSendTransactionalRequest(Sender.java:362) > 2019-04-17T01:58:25.898Z at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:214) > 2019-04-17T01:58:25.898Z at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163) > 2019-04-17T01:58:25.898Z at java.lang.Thread.run(Thread.java:748) > {quote} > Later, Kafka Streams (running with EOS enabled) shuts down with a > `TimeoutException` that occurs during rebalance. It seem that the above error > results in this `TimeoutException`. However, and `IllegalStateException` seem > to indicate a bug in the producer. -- This message was sent by Atlassian JIRA (v7.6.3#76005)