春云溪卡——频频"Attempt to heartbeat failed since group is rebalancing"



我有一个spring-boot应用程序,运行25个实例,有25个分区。它消耗消息,并通过从缓存中获取数据来进行一些计算,并将结果值放入数据库。

但该应用程序的性能非常差,即使有这么多实例,CPU使用率也非常高每笔交易花费的最长时间为6-8秒,平均时间-->700ms

在斯普伦克,在一分钟内,我看到这个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次。

我的问题是,为什么我经常收到这条消息??这(频繁地进行再平衡(会导致性能不佳吗。

有什么想法吗??

增加max.poll.interval和/或减少max.poll.records(Kafka消费者属性(。

最新更新