来自 Kafka 任务的 TaskId答案

【问题标题】：TaskId from Kafka Task来自 Kafka 任务的 TaskId
【发布时间】：2021-09-23 10:24:22
【问题描述】：

我正在尝试从我自己的 Kafka 连接器中导出一些自定义指标。我需要获取有关 SinkTask 的更多信息，尤其是 SinkTask 的 taskId。但是，我无法找到有关获取此 taskID 的任何文档或 API 参考。阅读源代码也没有任何亮点。我该怎么做？

【问题讨论】：

【解决方案1】：

请查看 Confluent 文档Monitoring Kafka Connect and Connectors: Sink task metrics：您可以从task 属性中获取 Sink 任务的 taskId。

【讨论】：

感谢您的回复。 SinkTask 没有名称task 的属性您提到的链接是REST API 文档和各种JMX 导出指标的概述。我无法从那里看到如何从task 获取taskId。
你可以从MBean中得到taskIdMBean: kafka.connect:type=sink-task-metrics,connector=([-.w]+),task=([d]+)：task=([d]+)属性是taskId
您如何尝试导出指标？你用jmx_exporter还是别的什么？
是的，我正在使用jmx_exporter 导出指标。此外，这听起来可能是一个非常微不足道的问题，但我如何从 SinkTask 对象中获取相应的 MBean。