在 relabance 期间,StreamThreads 的状态是什么?
During relabance what is the state of StreamThreads?
我正在学习Kafka Stream processors
并参考各种在线资料。在重新平衡期间,StreamThreads
的状态是什么,因此 StreamTasks
是什么状态。 StreamThreads
处于 "sleeping" 阶段还是在重新平衡后被销毁并重新创建?
我还在学习这些概念,所以如果这是一个基本概念,请原谅。
REBALANCING
是显式状态
REBALANCING if any of its threads is in PARTITION_REVOKED or PARTITIONS_ASSIGNED state - REBALANCING state will transit to RUNNING if all of its threads are in RUNNING state
https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
我正在学习Kafka Stream processors
并参考各种在线资料。在重新平衡期间,StreamThreads
的状态是什么,因此 StreamTasks
是什么状态。 StreamThreads
处于 "sleeping" 阶段还是在重新平衡后被销毁并重新创建?
我还在学习这些概念,所以如果这是一个基本概念,请原谅。
REBALANCING
是显式状态
REBALANCING if any of its threads is in PARTITION_REVOKED or PARTITIONS_ASSIGNED state - REBALANCING state will transit to RUNNING if all of its threads are in RUNNING state
https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/KafkaStreams.State.html