THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Polling can be monitored with Consumer fetch metrics, e.g. fetch-latency-avg/max
Predicates as implemented via PredicatedTransformation will be also measured.
Public Interfaces
The following metrics would be added at the Task Level:
...
kafka.connect:type=sink-task-transform-metrics,connector="{connector}",alias="{transform_alias}",task="{task}"
| Sensor / Recording Level | Attribute name | Description |
|---|---|---|
transform-sink-record-time (?) DEBUG |
| The average time taken by this task to apply specific transform included in this task. |
| The maximum time taken by this task to apply specific transform included in this task. |
kafka.connect:type=source-task-transform-metrics,connector="{connector}",alias="{transform_alias}",task="{task}"
| Sensor / Recording Level | Attribute name | Description |
|---|---|---|
transform-source-record-time DEBUG |
| The average time taken by this task to apply specific transform included in this task. |
| The maximum time taken by this task to apply specific transform included in this task. |
More granular metrics are recorded at DEBUG level to avoid performance impact.
...
Compatibility, Deprecation, and Migration Plan
ConnectConfig and TransformationChain users will have to migrate to the new interfaces. Though the updates APIs are used internally on Worker instantiations of Tasks.
Rejected Alternatives
If there are alternative ways of accomplishing the same thing, what were they? The purpose of this section is to motivate why the design is the way it is and not some other way.
...