我正在使用以下jmx指标进行kafka连接.
查看Kafka文档中的Connect Monitoring部分,它列出了所有Kafka Connect特定指标.
例如,每个连接器都有总体指标:
kafka.connect:type=connector-metrics,cOnnector="{connector}"
其中包含连接器状态(运行,失败等)
kafka.connect:type=connector-task-metrics,cOnnector="{connector}",task="{task}"
其中包含各个任务的状态
如果您不仅需要状态,还有接收器和源任务的其他指标:
kafka.connect:type=connector-task-metrics,cOnnector="{connector}",task="{task}"
kafka.connect:type=sink-task-metrics,cOnnector="{connector}",task="{task}"