检查 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 的默认值,假设它们会被覆盖。