首页 > 解决方案 > 如何添加自定义 Kafka Connect SinkTask 指标进行监控?

问题描述

我已阅读有关 Kafka Connect 监控的页面https://docs.confluent.io/current/connect/managing/monitoring.html 。目前尚不完全清楚如何定义和发出我自己的一组指标。例如,我想在 SinkTaskput()实现中发出当前 tiemstamp 和 ConnectRecord 时间戳之间的时间增量,这给了我端到端的延迟。目前未在接收器任务指标列表中定义。

如何为 SinkTask 监控添加自定义指标?

标签: apache-kafkaapache-kafka-connect

解决方案


推荐阅读