Versions Compared

Old Version 11

changes.mady.by.user Cyrus Vafadari

Saved on

compared with

New Version 12

changes.mady.by.user Cyrus Vafadari

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

MBeanMetric/Attribute NameDescription
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-total-task-countThe number of tasks of the connector. 
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-running-task-countThe number of running tasks of the connector.
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-paused-task-countThe number of paused tasks of the connector.
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-failed-task-countThe number of failed tasks of the connector.
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-unassigned-task-countThe number of unassigned tasks of the connector.
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-destroyed-task-countThe 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.

...