我正在尝试监视我的samza应用程序，它是使用beam api实现的。消费者延迟的计算（例如，使用此工具）基于提交的偏移量。但是samzas自己的检查点机制不允许将偏移提交回kafka enable.auto.commit=true ，使用配置文件和beam kafka i/o。然而，检查我的日志，我看到该选项仍然会设置为假。我试过使用jmx导出器。然而，检查发射的mbeans我无法找到该组 org.apache.samza.system.kafka.KafkaSystemConsumersMetrics 其中包含 metric messages-behind-high-watermark .