如何解决如何收集Samza应用程序的用户滞后时间?
我正在尝试监视我的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 举报,一经查实,本站将立刻删除。