Hi, In my application use camel-kafka component as a producer and consumer. For example:
from("kafka:...?topic=topic1") .process(new ChangeMessage()) to("kafka:...?topic=topic2") If change only body, producer send to topic1, because in.header this value "kafka.TOPIC=topic1". I would like to understand from the point of view of a component is the correct behavior? thanks for answers -- Best regards, Maks Kozlov