Versions Compared

Key

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

...

Metric NameDescriptionMBean attribute

assigned-tasks

The number of tasks run in this worker (existing metric)kafka.connect:type=connect-coordinator-metrics,name=assigned-tasks
assigned-connectorsThe number of connectors run in this worker (existing metric)kafka.connect:type=connect-coordinator-metrics,name=assigned-connectors

task-count

The number of tasks run in this workerkafka.connect:type=connect-worker-metrics,name=task-count
connector-countThe number of connectors run in this workerkafka.connect:type=connect-worker-metrics,name=connector-count
leader-nameThe name of the group leaderkafka.connect:type=connect-worker-metrics,name=leader-name 
stateThe state of this worker, one of: rebalancing, runningkafka.connect:type=connect-worker-metrics,name=state 
rest-request-rateThe average per second number of requests handled by the REST endpoints in this workerkafka.connect:type=connect-worker-metrics,name=rest-request-rate


Worker Rebalance Metrics

Metric NameDescriptionMBean attribute
rebalance-success-totalThe total number of this worker's successful rebalanceskafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-success-total
rebalance-success-percentageThe average percentage of this worker's rebalances that succeededkafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-success-percentage 
rebalance-failure-totalThe total number of this worker's failed rebalanceskafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-failure-total
rebalance-failure-percentageThe average percentage of this worker's rebalances that failedkafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-failure-percentage
rebalance-max-timeThe maximum time spent by this worker to rebalancekafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-max-time
rebalance-99p-timeThe 99th percentile time spent by this worker to rebalance during the last window (defaults to an hour)kafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-99p-time
rebalance-95p-timeThe 95th percentile time spent by this worker to rebalance during the last window (defaults to an hour)kafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-95p-time
rebalance-90p-timeThe 90th percentile time spent by this worker to rebalance during the last window (defaults to an hour)kafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-90p-time
rebalance-75p-timeThe 75th percentile time spent by this worker to rebalance during the last window (defaults to an hour)kafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-75p-time
rebalance-50p-timeThe 50th percentile (average) time spent by this worker to rebalance during the last window (defaults to an hour)kafka.connect:type=connect-worker-rebalance-metrics,name=rebalance-50p-time
time-since-last-rebalanceThe time since the most recent rebalance in this workerkafka.connect:type=connect-worker-rebalance-metrics,name=time-since-last-rebalance
task-failure-rateThe number of tasks that failed in this workerkafka.connect:type=connect-worker-rebalance-metrics,name=task-failure-rate

...

request
Metric NameDescriptionMBean attribute
-rateThe average per second number of requests handled by the REST endpoints in this workerkafka.connect:type=worker-rest-metrics,name=request-rate

...

Proposed Changes

We will add the relevant metrics as specified in the Public Interfaces section, except for the two existing metrics that will be left unmodified.

...