我有一个spring引导应用程序,运行有25个实例,有25个分区。它使用消息并通过从缓存中获取数据进行计算,并将结果值放入数据库。
但是该应用程序的性能非常差,即使在这许多实例中,CPU的使用率也很高。
在扣篮,马上,我看到这个message: [Consumer clientId=consumer-2, groupId=TEST] Attempt to heartbeat failed since group is rebalancing thread_name: kafka-coordinator-heartbeat-thread | CG.LOGICALINVENTORY-TEST大约200次。
我的问题是,为什么我经常收到这个信息?而这(频繁的再平衡)是否会导致性能不佳。
有什么想法吗?
发布于 2022-01-05 15:19:10
增加max.poll.interval和/或减少max.poll.records (卡夫卡消费者属性)。
https://stackoverflow.com/questions/70595164
复制相似问题