Eric created KAFKA-8313: --------------------------- Summary: KafkaStreams state not being updated properly after shutdown Key: KAFKA-8313 URL: https://issues.apache.org/jira/browse/KAFKA-8313 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 2.2.0 Environment: Single broker running on Ubuntu Linux. Reporter: Eric
I am running a KafkaStreams inside a DropWizard server and I am trying to detect when my stream shuts down (in case a non-recoverable error occurs). I was hoping I could use KafkaStreams.setStateListener() to be notified when a state change occurs. When I query the state, KafkaStreams is stuck in the REBALANCING state even though its threads are all DEAD. You can easily reproduce this by doing the following: # Create a topic (I have one with 5 partitions) # Create a simple Kafka stream consuming from that topic # Create a StateListener and register it on that KafkaStreams # Start the Kafka stream # Once everything runs, delete the topic using kafka-topics.sh When deleting the topic, you will see the StreamThreads' state transition from RUNNING to PARTITION_REVOKED and you will be notified with the KafkaStreams REBALANCING state. That's all good and expected. Then the StreamThreads transition to PENDING_SHUTDOWN and eventually to DEAD and the KafkaStreams state is stuck into the REBALANCING thread. I was expecting to see a NOT_RUNNING state eventually... am I right? -- This message was sent by Atlassian JIRA (v7.6.3#76005)