Source record converters


We provide four converters out of the box. The WITHCONVERTER keyword supports these options:

AvroConverter 

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.

JsonSimpleConverter 

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.

JsonConverterWithSchemaEvolution 

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.

BytesConverter 

io.lenses.streamreactor.connect.converters.source.BytesConverter
--
Last modified: June 18, 2024