检查 max.poll.interval.ms 和 max.poll.records 的值
Check the values of max.poll.interval.ms and max.poll.records
为了防止Kafka重平衡,我想增加max.poll.interval.ms
,减少max.poll.records
。
另外,我知道默认配置为:
max.poll.records = 500
max.poll.interval.ms = 300000
我不确定如何在 Kafka 消费者的现有实例上检查这些配置。
假设您使用的是 JVM-based 客户端,那么所有 ConsumerConfig
属性都是在 Consumer 实例化时从 log4j 打印出来的,因此请确保您的日志记录客户端设置正确。
对于任何其他客户端,您必须深入研究 source-code 的默认值,假设它们会被覆盖。
为了防止Kafka重平衡,我想增加max.poll.interval.ms
,减少max.poll.records
。
另外,我知道默认配置为:
max.poll.records = 500
max.poll.interval.ms = 300000
我不确定如何在 Kafka 消费者的现有实例上检查这些配置。
假设您使用的是 JVM-based 客户端,那么所有 ConsumerConfig
属性都是在 Consumer 实例化时从 log4j 打印出来的,因此请确保您的日志记录客户端设置正确。
对于任何其他客户端,您必须深入研究 source-code 的默认值,假设它们会被覆盖。