为什么Kafka流应用程序重新平衡?

thtygnil  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(244)

为了进行测试,我们正在针对单节点代理部署一个kafka流应用程序,使用kafka 0.11.0.2。应用程序保持再平衡,即通过使用

kafkaStreams.setStateListener()

在日志记录中,我们通常会看到以下几行:

18:06:15.222 State changed from RUNNING to REBALANCING
18:06:15.766 State changed from REBALANCING to REBALANCING
18:06:15.964 State changed from REBALANCING to RUNNING

如果我们增加kafka.num.threads,这种情况会在流应用程序稳定之前发生更多时间。是什么触发了再平衡?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题