We provide four converters out of the box. The WITHCONVERTER keyword supports these options:
io.lenses.streamreactor.connect.converters.source.AvroConverter
The payload is an Avro message. In this case you need to provide a path for the Avro schema file to be able to decode it.
io.lenses.streamreactor.connect.converters.source.JsonSimpleConverter
The payload is a JSON message. This converter will parse the JSON and create an Avro record for it which will be sent over to Kafka.
An experimental converter for translating JSON messages to Avro. The resulting Avro schema is fully compatible as new fields are added as the JSON payload evolves.
io.lenses.streamreactor.connect.converters.source.BytesConverter
On this page
