我有一个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消费者属性(。