Versions Compared

Key

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

...

Metric/Attribute NameDescription
sink-record-read-rateThe 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-rateThe 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-maxThe maximum lag in terms of number of records behind the consumer the offset commits are for any topic partitions.
partition-countThe number of topic partitions assigned to this task belonging to the named sink connector in this worker.
commit-seq-noThe current sequence number for commits
commit-completion-rateThe average per-second number of commit completions that were completed successfully
commit-completion-skip-rateThe average per-second number of commit completions that were recieved too late and skipped/ignored
offset-commitflush-max-timeThe maximum time taken by this sink task to pre-commit offsets to the sink
offset-commitflush-99p-timeThe 99th percentile time spent by this sink task to pre-commit offsets to the sink/flush
flushoffset-commit-95p-timeThe 95th percentile time spent by this sink task to pre-commit offsets to the sink/flush
flushoffset-commit-90p-timeThe 90th percentile time spent by this sink task to pre-commit offsets to the sink/flush
flushoffset-commit-75p-timeThe 75th percentile time spent by this sink task to pre-commit offsets to the sink/flush
flush-offset-commit-50p-timeThe 50th percentile (average) time spent by this sink task to pre-commit offsets to the sink/flush


MBean namekafka.connect:type=sink-task-metrics,connector=([-.\w]+),task=([\d]+),topic=([-.\w]+),partition=([\d]+)

...