Description
For a multi threaded Streams instance, it can happen that one thread dies while all other threads (within a single instance) keep running. Even if this is an rare scenario, we should allow querying the stores after rebalance finished. However, this does never happen, as the died thread's state is still in KafkaStreams thread state map (as NOT_RUNNING), and thus, KafkaStreams itself is in state REBALANCING all the time and does not transit back to RUNNING.
Attachments
Issue Links
- links to