为何Kafka Streams应用频繁重平衡？基于Kafka 0.11.0.2的测试问题

最近我们在单节点Kafka 0.11.0.2 Broker环境下部署Kafka Streams应用做测试时，遇到了一个头疼的问题——应用持续发生重平衡。

为了追踪状态变化，我们通过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参数时，重平衡发生的次数居然会显著增多，这进一步加剧了问题的影响。

内容的提问来源于stack exchange，提问作者Edmondo