You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by tapdur <ta...@gmail.com> on 2014/12/08 12:46:21 UTC
kafka inout issue
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&zookeeperHost=localhost&zookeeperPort=2181&producerType=sync&serializerClass=kafka.serializer.StringEncoder"/>
<log message="Provider Bonjour OUT Got ${body}"/>
</route>
and the consumer route
<route>
<from
uri="kafka:localhost:9092?topic=bonjour&zookeeperHost=localhost&zookeeperPort=2181&groupId=group1&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.
Re: kafka inout issue
Posted by Claus Ibsen <cl...@gmail.com>.
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 <ta...@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&zookeeperHost=localhost&zookeeperPort=2181&producerType=sync&serializerClass=kafka.serializer.StringEncoder"/>
>
>
>
> <log message="Provider Bonjour OUT Got ${body}"/>
> </route>
>
> and the consumer route
> <route>
>
>
>
>
> <from
> uri="kafka:localhost:9092?topic=bonjour&zookeeperHost=localhost&zookeeperPort=2181&groupId=group1&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: cibsen@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/