当通过kafka consumer api检索消费者度量时，records lag max偶尔返回0，即使使用kafka-consumer-groups.sh工具描述消费者组显示消费者滞后。metrics.sample.window.ms默认设置为30s，metrics.num.samples默认设置为2。metrics.num.samples如何影响记录lag max的计算？
当通过kafka consumer api检索消费者度量时，records lag max偶尔返回0，即使使用kafka-consumer-groups.sh工具描述消费者组显示消费者滞后。metrics.sample.window.ms默认设置为30s，metrics.num.samples默认设置为2。metrics.num.samples如何影响记录lag max的计算？
1条答案
按热度按时间dw1jzc5e1#
我认为没有任何效果。
records lag-*由fetch response结构的latest offset字段驱动，它告诉客户机分区的“边缘”在代理上的位置。然后，客户机将该偏移量与实际获取响应中返回的最新偏移量进行比较，以确定它“落后”于代理的记录数。
每次从代理接收到回迁响应时，这些度量都会更新，如果在任何此类回迁响应到达之前查询这些度量，则可能会看到0。
另一方面，kafka消费者组不会向您显示任何特定消费者“在哪里”（向该消费者提供的最新偏移量），而是显示该消费者最后一次检查到kafka的偏移量。消费者检查点偏移周期性地（通常每30-60秒一次），因此描述消费者组可以显示非0滞后，其中消费者本身的度量（更新更频繁）将显示0。