我正在学习Kafka Stream processors,并参考各种在线材料。在重新平衡StreamThreads和so的状态时,StreamTasks。StreamThreads是处于“睡眠”阶段,还是在再平衡之后被破坏和重新创造?
我还在学习这些概念,所以如果这是一个基本概念,请原谅。
发布于 2020-01-19 21:08:25
REBALANCING是一个显式状态。
如果
的任何线程处于PARTITION_REVOKED或PARTITIONS_ASSIGNED状态--如果其所有线程都处于运行状态,则重新平衡状态将转换为运行状态。
https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
https://stackoverflow.com/questions/59812582
复制相似问题