Versions Compared

Key

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

...

In this example we are going to deserialize the value to json, we can do this without using a schemaa string. (Same producer as the influxdb example)

...

We will need to create our own TypeConverter and include it with the camel connector if we want to deserialize to jsonusing org.apache.kafka.connect.json.JsonConverter.

The minio connection details are specified in camel.kamelet.minio-sink parameters.

...