[KAFKA-14717] KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.5.0
• Component/s: streams
• Assignee: Chia-Ping Tsai
• Reporter: Chia-Ping Tsai
• Created: 14/Feb/23 19:37
• Updated: 24/Feb/23 19:46
• Resolved: 24/Feb/23 19:46

Description

I noticed this issue when tracing KAFKA-7109

StreamThread closes the consumer before changing state to DEAD. If the partition rebalance happens quickly, the other StreamThreads can't change KafkaStream state from REBALANCING to RUNNING since there is a PENDING_SHUTDOWN StreamThread

Issue Links

• links to: GitHub Pull Request #13248