THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
MBean | Metric/Attribute Name | Description |
---|---|---|
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-total-task-count | The number of tasks of the connector. |
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-running-task-count | The number of running tasks of the connector. |
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-paused-task-count | The number of paused tasks of the connector. |
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-failed-task-count | The number of failed tasks of the connector. |
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-unassigned-task-count | The number of unassigned tasks of the connector. |
kafka.connect:type=connector-metrics,connector=([-.\w]+) | connector-destroyed-task-count | The number of destroyed tasks of the connector. |
Since each task must always have exactly one non-null status, and we've covered every task status, the "connector-total-task-count" will be equal to the sum of each status.
Proposed Changes
The above metrics will be added. These metric will be calculated from the `Herder::connectorStatus` method. In order to enable this change, the `WorkerConnector` will be constructed with a `Herder` to have access to the task statuses.
...