...
MBean name: kafka.connect:type=connector-metrics,connector=([-.\w]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
connector-type | The type of the connector, one of: source, sink |
connector-class | The name of the connector class |
connector-version | The version of the connector class, as reported by the connector in this worker |
status | The current status of the connector in this worker, one of: running, paused, stopped |
...
MBean name: kafka.connect:type=task-metrics,connector=([-.\w]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
status | The current status of this task, one of: unassigned, running, paused, failed, destroyed |
pause-ratio | The fraction of time this task has spent in the paused state. |
offset-commit-success-percentage | The average percentage of this task's offset commit attempts that succeeded |
offset-commit-failure-percentage | The average percentage of this task's offset commit attempts that failed or had an error |
offset-commit-max-time | The maximum time taken by this task to commit offsets |
offset-commit-99p-time | The 99th percentile time spent by this task to commit offsets to Kafka |
offset-commit-95p-time | The 95th percentile time spent by this task to commit offsets to Kafka |
offset-commit-90p-time | The 90th percentile time spent by this task to commit offsets to Kafka |
offset-commit-75p-time | The 75th percentile time spent by this task to commit offsets to Kafka |
offset-commit-50p-time | The 50th percentile (average) time spent by this task to commit offsets to Kafka |
batch-size-max | The maximum size of the batches processed by the connector |
batch-size-avg | The average size of the batches processed by the connector |
...
MBean name: kafka.connect:type=source-task-metrics,connector=([-.\w]+),task=([\d]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
source-record-poll-rate | The average per-second number of records produced/polled (before transformation) by this task belonging to the named source connector in this worker. This is before transformations are applied. |
source-record-write-rate | The average per-second number of records per second output from the transformations and written to Kafka for this task belonging to the named source connector in this worker. This is after transformations are applied. |
...
MBean name: kafka.connect:type=sink-task-metrics,connector=([-.\w]+),task=([\d]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
sink-record-read-rate | The average per-second number of records read from Kafka for this task belonging to the named sink connector in this worker. This is before transformations are applied. |
sink-record-send-rate | The average per-second numbrer of records output from the transformations and sent to this task belonging to the named sink connector in this worker. This is after transformations are applied and excludes any records filtered out by the transformations. |
sink-record-lag-max | The maximum lag in terms of number of records behind the consumer the offset commits are for any topic partitions. |
partition-count | The number of topic partitions assigned to this task belonging to the named sink connector in this worker. |
commit-seq-no | The current sequence number for commits |
commit-completion-rate | The average per-second number of commit completions that were completed successfully |
commit-completion-skip-rate | The average per-second number of commit completions that were recieved too late and skipped/ignored |
offset-commit-max-time | The maximum time taken by this sink task to pre-commit offsets to the sink |
offset-commit-99p-time | The 99th percentile time spent by this sink task to pre-commit offsets to the sink |
offset-commit-95p-time | The 95th percentile time spent by this sink task to pre-commit offsets to the sink |
offset-commit-90p-time | The 90th percentile time spent by this sink task to pre-commit offsets to the sink |
offset-commit-75p-time | The 75th percentile time spent by this sink task to pre-commit offsets to the sink |
offset-commit-50p-time | The 50th percentile (average) time spent by this sink task to pre-commit offsets to the sink |
MBean name: kafka.connect:type=sink-task-metrics,connector=([-.\w]+),task=([\d]+),topic=([-.\w]+),partition=([\d]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
sink-record-lag | The latest lag in terms of number of records behind the consumer the offset commits are for the topic partition. |
sink-record-lag-avg | The average lag in terms of number of records behind the consumer the offset commits are for the topic partition. |
sink-record-lag-max | The maximum lag in terms of number of records behind the consumer the offset commits are for the topic partition. |
...
MBean name: kafka.connect:type=connect-worker-metrics,connector=([-.\w]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
assigned-tasks | The number of tasks run in this worker (mirrors existing metric) |
assigned-connectors | The number of connectors run in this worker (mirrors existing metric) |
task-count | The number of tasks run in this worker |
connector-count | The number of connectors run in this worker |
leader-name | The name of the group leader |
epoch | The epoch or generation number of this worker |
state | The state of this worker, one of: rebalancing, running |
rest-request-rate | The average per second number of requests handled by the REST endpoints in this worker |
...
MBean name: kafka.connect:type=connect-worker-rebalance-metrics,connector=([-.\w]+)
Metric (MBean /Attribute ) Name | Description |
---|---|
rebalance-success-total | The total number of this worker's successful rebalances |
rebalance-success-percentage | The average percentage of this worker's rebalances that succeeded |
rebalance-failure-total | The total number of this worker's failed rebalances |
rebalance-failure-percentage | The average percentage of this worker's rebalances that failed |
rebalance-max-time | The maximum time spent by this worker to rebalance |
rebalance-99p-time | The 99th percentile time spent by this worker to rebalance during the last window (defaults to an hour) |
rebalance-95p-time | The 95th percentile time spent by this worker to rebalance during the last window (defaults to an hour) |
rebalance-90p-time | The 90th percentile time spent by this worker to rebalance during the last window (defaults to an hour) |
rebalance-75p-time | The 75th percentile time spent by this worker to rebalance during the last window (defaults to an hour) |
rebalance-50p-time | The 50th percentile (average) time spent by this worker to rebalance during the last window (defaults to an hour) |
time-since-last-rebalance | The time since the most recent rebalance in this worker |
task-failure-rate | The number of tasks that failed in this worker |
...