Versions Compared

Old Version 6

changes.mady.by.user Jorge Otoya

Saved on

compared with

New Version 7

changes.mady.by.user Jorge Otoya

Saved on

Key

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

...

kafka.connect:type=sink-task-metrics,connector="{connector}",task="{task}"

Attribute nameDescription
  • sink-record-latency-max-ms

The maximum latency of a record, measuring by comparing the record timestamp with the system time when it has been received by the Sink task

  • sink-record-latency-avg-ms
The average latency of a record, measuring by comparing the record timestamp with the system time when it has been received by the Sink task
  • sink-record-convert-transform-time-max-ms
The maximum time taken by this task to convert and transform a record.
  • sink-record-convert-transform-time-avg-ms
The average time taken by this task to convert and transform a record.


kafka.connect:type=source-task-metrics,connector="{connector}",task="{task}"

Attribute nameDescription
  • source-record-transform-convert-time-max-ms

The maximum time in milliseconds taken by this task to transform and convert for a record.

  • source-record-transform-convert-time-avg-ms
The average time in milliseconds taken by this task to transform and convert for a record.


All these metrics will be recorded at DEBUG level, as the metrics are recorded at individual record level, compared to all other metrics recorded at batch level.

Proposed Changes

Sink Connectors have 3 stages:

...