cKafka Extract Topic and Mesasge Body

[datajunkie1000]

Hi All

I have a route with a cKafka component set up to consume messages. The Component is successfully listening to the topic. How would I get the topic name and message body from the cKafka component?

My aim is to pass the topic and message body to a DIJob

[datajunkie1000 · Accepted solution]

Turns out that the Kafka message body is just referenced as ${in.body}