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. This is before transformations are applied |
| source-record-poll-count | The 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-count | The 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. |
Sink Task Metrics
MBean name: kafka.connect:type=sink-task-metrics,connector=([-.\w]+),task=([\d]+)
...
| Metric/Attribute Name | Description | |
|---|---|---|
| sink-record-read-rate | The average per-second number of records read from | Kafka forKafka (before transformations are applied) for this task belonging to the named sink connector in this worker. |
| sink-record-read-count | The number of records read from Kafka ( This is 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-count | The numbrer 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-skip-rate | The average per-second number of offset commit completions that were received too late and skipped/ignored | |
| flush-max-time | The maximum time taken by this sink task to pre-commit/flush | |
| flush-99p-time | The 99th percentile time spent by this sink task to pre-commit/flush | |
| flush-95p-time | The 95th percentile time spent by this sink task to pre-commit/flush | |
| flush-90p-time | The 90th percentile time spent by this sink task to pre-commit/flush | |
| flush-75p-time | The 75th percentile time spent by this sink task to pre-commit/flush | |
| flush-50p-time | The 50th percentile (average) time spent by this sink task to pre-commit/flush |
...