THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Metric/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. |
| source-record-poll-counttotal | The total number of records produced/polled (before transformation) by this task belonging to the named source connector in this worker, since the task was last restarted. |
| source-record-write-rate | The average per-second number of records 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 and excludes any records filtered out by the transformations. |
| source-record-write-counttotal | The total number of records output from the transformations and written to Kafka for this task belonging to the named source connector in this worker, since the task was last restarted. |
| poll-batch-max-time-ms | The maximum time in milliseconds taken by this task to poll for a batch of source records |
| poll-batch-99p-time-ms | The 99th percentile time in milliseconds spent by this task to poll for a batch of source records |
| poll-batch-95p-time-ms | The 95th percentile time in milliseconds spent by this task to poll for a batch of source records |
| poll-batch-90p-time-ms | The 90th percentile time in milliseconds spent by this task to poll for a batch of source records |
| poll-batch-75p-time-ms | The 75th percentile time in milliseconds spent by this task to poll for a batch of source records |
| poll-batch-50p-time-ms | The 50th percentile (average) time in milliseconds spent by this task to poll for a batch of source records |
...
| Metric/Attribute Name | Description |
|---|---|
| sink-record-read-rate | The average per-second number of records read from Kafka (before transformations are applied) for this task belonging to the named sink connector in this worker. |
| sink-record-read-counttotal | The total number of records read from Kafka (before transformations are applied) for this task belonging to the named sink connector in this worker, since the task was last restarted. |
| 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-send-counttotal | The numbrer total number of records output from the transformations and sent to this task belonging to the named sink connector in this worker, since the task was last restarted. |
| 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. |
| offset-commit-seq-no | The current sequence number for offset commits |
| offset-commit-completion-rate | The average per-second number of offset commit completions that were completed successfully |
| offset-commit-completion-total | The total number of offset commit completions that were completed successfully |
| offset-commit-completion-skip-rate | The average per-second number of offset commit completions that were received too late and skipped/ignored |
| offset-commit-completion-skip-total | The total number of offset commit completions that were received too late and skipped/ignored |
| put-batch-max-time-ms | The maximum time taken by this task to put a batch of sinks records |
| put-batch-99p-time-ms | The 99th percentile time in milliseconds spent by this task to put a batch of sinks records |
| put-batch-95p-time-ms | The 95th percentile time in milliseconds spent by this task to put a batch of sinks records |
| put-batch-90p-time-ms | The 90th percentile time in milliseconds spent by this task to put a batch of sinks records |
| put-batch-75p-time-ms | The 75th percentile time in milliseconds spent by this task to put a batch of sinks records |
| put-batch-50p-time-ms | The 50th percentile (average) time in milliseconds spent by this task to put a batch of sinks records |
| flush-max-time-ms | The maximum time in milliseconds taken by this sink task to pre-commit/flush |
| flush-99p-time-ms | The 99th percentile time in milliseconds spent by this sink task to pre-commit/flush |
| flush-95p-time-ms | The 95th percentile time in milliseconds spent by this sink task to pre-commit/flush |
| flush-90p-time-ms | The 90th percentile time in milliseconds spent by this sink task to pre-commit/flush |
| flush-75p-time-ms | The 75th percentile time in milliseconds spent by this sink task to pre-commit/flush |
| flush-50p-time-ms | The 50th percentile (average) time in milliseconds spent by this sink task to pre-commit/flush |
...
| Metric/Attribute Name | Description |
|---|---|
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 |
| status | The state of this worker, one of: rebalancing, running |
| status-rebalancing | Signals whether the worker is in the rebalancing state |
| status-running | Signals whether the worker is in the running state |
| rest-request-rate | The average per second number of requests handled by the REST endpoints in this worker |
| rest-request-total | The total number of requests handled by the REST endpoints in this worker, since the worker was last restarted. |
Worker Rebalance Metrics
MBean name: kafka.connect:type=connect-worker-rebalance-metrics
...
| Metric/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-ms | The maximum time in milliseconds spent by this worker to rebalance |
| rebalance-99p-time-ms | The 99th percentile time in milliseconds spent by this worker to rebalance during the last window (defaults to an hour) |
| rebalance-95p-time-ms | The 95th percentile time in milliseconds spent by this worker to rebalance during the last window (defaults to an hour) |
| rebalance-90p-time-ms | The 90th percentile time in milliseconds spent by this worker to rebalance during the last window (defaults to an hour) |
| rebalance-75p-time-ms | The 75th percentile time in milliseconds spent by this worker to rebalance during the last window (defaults to an hour) |
| rebalance-50p-time-ms | The 50th percentile (average) time in milliseconds spent by this worker to rebalance during the last window (defaults to an hour) |
| time-ms-since-last-rebalance | The time in milliseconds since the most recent rebalance in this worker |
| task-failure-rate | The average per second number of tasks that failed in this worker |
| task-failure-total | The total number of tasks that failed in this worker |
...