A Kafka Connect plugin that uses a JSONata expression to transform the Kafka Connect record.
You can install or download the latest version of the plugin from Confluent Hub.
Skip tombstone records:
"transforms": "jsonata",
"transforms.jsonata.type": "io.yokota.kafka.connect.transform.jsonata.JsonataTransformation",
"transforms.jsonata.expr": "value = null ? null : $"
Drop the record key and it's schema:
"transforms": "jsonata",
"transforms.jsonata.type": "io.yokota.kafka.connect.transform.jsonata.JsonataTransformation",
"transforms.jsonata.expr": "$sift($, function($v, $k) {$k != 'keySchema' and $k != 'key'})"
For more examples, see this blog.
The JSONata expression to apply to the Kafka Connect record.
The maximum amount of time to wait (in ms) for the JSONata transformation to complete. Default is 5000.
The maximum number of recursive calls allowed for the JSONata transformation. Default is 1000.
This codebase is licensed under the Apache License 2.0. See the
LICENSE file for more details.