You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2023/02/14 19:38:00 UTC
[jira] [Created] (KAFKA-14717) KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely
Chia-Ping Tsai created KAFKA-14717:
--------------------------------------
Summary: KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely
Key: KAFKA-14717
URL: https://issues.apache.org/jira/browse/KAFKA-14717
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
Fix For: 3.5.0
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
--
This message was sent by Atlassian Jira
(v8.20.10#820010)