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

Reply via email to