[CAMEL-11193] Route from kafka topic to another kafka topic issue

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.19.0
• Fix Version/s: 2.19.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Claus Ibsen
• Created: 24/Apr/17 09:35
• Updated: 24/Apr/17 11:35
• Resolved: 24/Apr/17 11:35

Description

Because the consumer set headers with kafka topic and partition from the consumer, then these will override the endpoint configured on the producer, eg

from("kafka:foo")
   ..
   to("kafka:bar")

will end up going back to foo.

You can remove the headers to make it work

from("kafka:foo")
   ..
   removeHeaders("kafka*")
   to("kafka:bar")

But maybe we should have an option on the producer that takes the endpoint value always, and you need to turn the option on to allow header overrides.

Another option is to detect that its the same topic to avoid sending it back to itself.