Versions Compared

Key

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

...

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

...

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

Sensor /  Recording LevelAttribute nameDescription

transform-source-record-time

DEBUG

  • transform-source-record-time-avg-ms
The average time taken by this task to apply specific transform included in this task.
  • transform-source-record-time-max-ms
The maximum time taken by this task to apply specific transform included in this task.

Where alias  is the Transform alias name used in configuration:

Code Block
"transforms": "routeRecords",
"transforms.routeRecords.type": "org.apache.kafka.connect.transforms.RegexRouter"

"routeRecords" in this example.

More granular metrics are recorded at DEBUG level to avoid performance impact.

...