RAHUL JAIN created CAMEL-8923:
---------------------------------

             Summary: Kafka: Topic name lookup from message headers in the 
producer causes infinite loop
                 Key: CAMEL-8923
                 URL: https://issues.apache.org/jira/browse/CAMEL-8923
             Project: Camel
          Issue Type: Bug
          Components: camel-kafka
    Affects Versions: 2.15.1
            Reporter: RAHUL JAIN


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. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to