问题描述
我正在尝试监视我的Samza应用程序，这些应用程序是通过Beam API实现的。使用者延迟（例如with this tool）的计算基于提交的偏移量。但是Samzas自己的检查点机制不允许将偏移量提交回Kafka。要获取当前偏移量，我尝试使用配置文件和Beam Kafka I / O设置enable.auto.commit=true。但是检查我的日志，我发现该选项仍将设置为false。我尝试使用JMX-Exporter。但是，在检查发出的MBean时，我无法找到包含org.apache.samza.system.kafka.KafkaSystemConsumersMetrics的{{1}}组。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）