我编写了一个流应用程序来与5个分区的5个代理的集群上的主题交谈。我在这里尝试了多个组合,例如10个应用程序实例(在10个不同的机器上),每个具有1个流线程,5个实例,每个具有2个线程。但由于某种原因,当我检查kafka管理器时,分区和流线程之间的1:1映射没有发生。有些线程正在拾取2个分区,而有些则没有接收。你能帮我一下吗?所有线程都是同一组的一部分,只订阅了一个主题。我们使用的kafka流版本是0.11.0.2,代理版本是0.10.0.2
谢谢你的帮助
也许你正在打https://issues.apache.org/jira/browse/KAFKA-7144 - 我建议升级到最新版本。
注意:您无需升级经纪人