THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| MBean | Metric/Attribute Name | Description |
|---|---|---|
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-total-task-count | The number of tasks of the connector on the worker. |
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-running-task-count | The number of running tasks of the connector on the worker. |
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-paused-task-count | The number of paused tasks of the connector on the worker. |
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-failed-task-count | The number of failed tasks of the connector on the worker. |
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-unassigned-task-count | The number of unassigned tasks of the connector on the worker. |
kafka.connect:type=connect-worker-metrics,connector=([-.\w]+) | connector-destroyed-task-count | The number of destroyed tasks of the connector on the worker. |
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.
...
Then the metrics will be:
W1 reports:
| MBean | Metric Name | Value |
|---|---|---|
kafka.connect:type=connect-worker-metrics,connector=C1 | connector-total-task-count | 2 |
kafka.connect:type=connect-worker-metrics,connector=C2 | connector-total-task-count | 1 |
and similar values for each of the "running", "paused", "failed", "unassigned", and "destroyed" statuses.
W2 reports:
| Bean | Metric Name | Value |
|---|---|---|
kafka.connect:type=connect-worker-metrics,connector=C1 | connector-total-task-count | 2 |
kafka.connect:type=connect-worker-metrics,connector=C2 | connector-total-task-count | 1 |
and similar values for each of the "running", "paused", "failed", "unassigned", and "destroyed" statuses.
...