[
https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831841#comment-16831841
]
Eric commented on KAFKA-8313:
-----------------------------
I have added two files to the issue:
* kafka-8313-src.tgz: contains all the source code and maven setup to
replicate the issue
* log.txt: full execution log in DEBUG of the source code above
As you can see in the code, I have added a
KafkaStreams#setUncaughtExceptionHandler(), but it is never called. Every line
in the log from my source code is prefixed by '######' so you can easily see
what is going on.
As I explained, you'll need to create a topic named 'input' before running the
code. When the application starts, you have 30 seconds to delete the topic.
The Kafka stream will be closed when that timer is over.
I tried to debug that issue, but I couldn't run (in debug) Kafka from my
Eclipse. Let me know if you need more explanations.
> 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
> Priority: Minor
> Attachments: kafka-8313-src.tgz, log.txt
>
>
> 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)
