Versions Compared

Key

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

...

We propose adding the new metric "connector-task-count" on the existing group name "connector-metrics" in the ConnectMetricsRegistry.

MBeanMetric/Attribute NameDescription
kafka.connect:type=connector-metrics,connector=([-.\w]+)connector-task-countThe number of tasks of the connector. 

Proposed Changes

A new Connector level metric will be added, "connector-task-count". This metric will be calculated from the `Herder::connectorInfo` connectorStatus` method. In order to enable this change, the `WorkerConnector` will be constructed with a `Herder` to have access to the task statuses.

Metrics gathering should perform efficiently and be cheap to calculate. The newly proposed metric will call "AbstractHerder::connectorStatus", which synchronously returns the values from the KafkaStatusBackingStore's cache. The most expensive part of the function is sorting the taskStates.

Compatibility, Deprecation, and Migration Plan

...