相关疑难解决方法(0)

由于消息的吞吐量很高，我们增加了分区的数量以并行处理消息。一旦我们增加了分区的数量，订阅该主题的所有流线程就会死亡。我们更改了消费者组 ID，然后我们重新启动了它运行良好的应用程序。

我知道应用程序的分区更改日志主题的数量应该与源主题相同。我想知道这背后的原因。

我看到了这个链接 - https://issues.apache.org/jira/browse/KAFKA-6063?jql=project%20%3D%20KAFKA%20AND%20component%20%3D%20streams%20AND%20text%20~% 20%22分区%22

找不到原因

https://github.com/apache/kafka/blob/fdc742b1ade420682911b3e336ae04827639cc04/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java#L122

基本上，这背后的原因 if 条件。