Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-11193

Route from kafka topic to another kafka topic issue

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.19.0
    • Fix Version/s: 2.19.0
    • Component/s: camel-kafka
    • Labels:
      None
    • Estimated Complexity:
      Unknown

      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.

        Attachments

          Activity

            People

            • Assignee:
              davsclaus Claus Ibsen
              Reporter:
              davsclaus Claus Ibsen
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: