camel-kafka-connector
camel-kafka-connector copied to clipboard
Convert Struct to Map in the core so it can be used by JsonConverter, AvroConverter .. etc
There are components/connectors that need the message body to be in form of Map, for example Camel Stitch, Camel SQL .. etc. Hence if you have a JSON data message from Kafka, e.g:
{
"name" : "joe doe",
"id": 12
}
The SMT should be able to convert this to Map datatype. e.g:
map.get("name");
map.get("id");
It is not necessary, the JsonConverter can do this, however we need to convert the Struct to map