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

Kafka: Topic name lookup from message headers in the producer causes infinite loop

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.15.1
    • Fix Version/s: 2.16.0, 2.15.4
    • Component/s: camel-kafka
    • Labels:
      None
    • Estimated Complexity:
      Unknown

      Description

      Refer changes done for CAMEL-7331

      The change causes a critical bug.
      For a camel route as follows:

      from("kafka://<broker>?topic=T1")
      .process(myProcessor)
      .to("kafka://<broker>?topic=T2")
      

      KafkaExchange will be created by KafkaConsumer and the topic will be set to "T1" in the header.
      For the 'to' endpoint, KafkaProducer will try to read the topic from the exchange header which is still "T1" instead of "T2" thereby causing an infinite loop.

      As discussed in user-group, a different header should be used to read the topic name from message.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                njiang Willem Jiang
                Reporter:
                rahulj51 RAHUL JAIN
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: