Re: kafka inout issue

[Claus Ibsen]

Hi

The kafka component does not support doing request/reply style
messaging. Though if this would be possible with kafka, then sure we
love contributions to help implement support for this.
http://camel.apache.org/contributing.html

On Mon, Dec 8, 2014 at 12:46 PM, tapdur <tapdu...@gmail.com> wrote:
> 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.



-- 
Claus Ibsen
-----------------
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/