kafka inout issue

[tapdur]

Hi the community,

i have a route wich work well based on activeMQ from http .. to
direct:provider to activemq:consumer and a consumer wich is listen on from
activemq:consumer and reply a consumer msg.

i then migrate to Kafka. The consumer receive the topic message, tranform it
but the provider never receive the response and http response return with
the provider default response and not the consumer response.

here is the provider route wich never receive the consumer reponse : 

                        <from uri="direct:bonjour" />
                        <transform>
                                <constant>Le Provider répond Hello les 
consumers</constant>
                        </transform>
                        <setHeader headerName="kafka.PARTITION_KEY">
                                   <constant>kafka.PARTITION_KEY</constant>     
   
                        </setHeader>
                        <log message="Provider Bonjour IN  Got ${body}"/>
                <setExchangePattern pattern="InOut"/>

                        <to
uri="kafka:localhost:9092?topic=bonjour&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;producerType=sync&amp;serializerClass=kafka.serializer.StringEncoder"/>



                        <log message="Provider Bonjour OUT  Got ${body}"/>
                </route>
  
and the consumer route
                <route>
                        



                                <from
uri="kafka:localhost:9092?topic=bonjour&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;groupId=group1&amp;serializerClass=kafka.serializer.StringEncoder"/>
                                        <transform>
                                                <constant>${body} et le 
consumer dit aussi bonjour</constant>
                                        </transform>
                                
                                        <log message="Bonjour OUT  Got 
${body}"/>

is it a kafka component  issue ?

best regards
Bruno



--
View this message in context: 
http://camel.465427.n5.nabble.com/kafka-inout-issue-tp5760294.html
Sent from the Camel - Users mailing list archive at Nabble.com.