为了进行测试,我们正在针对单节点代理部署一个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,这种情况会在流应用程序稳定之前发生更多时间。是什么触发了再平衡?
暂无答案!
目前还没有任何答案,快来回答吧!