You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by darwinanirudh <da...@gmail.com> on 2017/05/26 06:49:45 UTC
Apache Camel kakfa Component making the route run continously
infinitely
Dear All,
This is my route:
<log message="zero" />
<log message="zero body is :${body}" />
<to uri="bean:Display?method=process" />
<log message ="before kakfa " />
<to ref="callkafkaSuspenseProducer" />
<log message ="after kakfa " />
<to ref="callEventRestService" />
<to uri="bean:Display1?method=process" />
callkafkaSuspenseProducer reference is mentioned in the comment line for
reference.
This behaviour is observed only after adding the apache kakfa component in
the route else it works fine.
The route keeps repeating endlessly. Request your help on this
regards
Darwin
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-kakfa-Component-making-the-route-run-continously-infinitely-tp5800761.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache Camel kakfa Component making the route run continously
infinitely
Posted by darwinanirudh <da...@gmail.com>.
Thank you for the response.
Apologies if i am wrong , the producer and consumer should have the same
topic name if i am not wrong?
callkafkaSuspenseProducer- This is the producer.
callkafkaSuspenseConsumer - This is the consumer.
regards
Darwin
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-kakfa-Component-making-the-route-run-continously-infinitely-tp5800761p5801356.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache Camel kakfa Component making the route run continously infinitely
Posted by Claus Ibsen <cl...@gmail.com>.
It looks like you use the same topic name, and then send the messages
back to yourself
On Fri, May 26, 2017 at 9:26 AM, darwinanirudh <da...@gmail.com> wrote:
> Kakfa consumer and producer for the above post
>
> <endpoint id="callkafkaSuspenseProducer"
>
> uri="kafka:${kafkaserver}?topic=SuspendedCdr3&zookeeperHost=${zookeeperHost}&zookeeperPort=${zookeeperport}&serializerClass=kafka.serializer.StringEncoder&producerType=sync"
> />
>
> <endpoint id="callkafkaSuspenseConsumer"
>
> uri="kafka:${kafkaserver}?topic=SuspendedCdr3&zookeeperHost=${zookeeperHost}&zookeeperPort=${zookeeperport}&serializerClass=kafka.serializer.StringEncoder&autoOffsetReset=smallest&groupId=default&consumerId=1"
> />
>
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-kakfa-Component-making-the-route-run-continously-infinitely-tp5800761p5800765.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
Re: Apache Camel kakfa Component making the route run continously
infinitely
Posted by darwinanirudh <da...@gmail.com>.
Kakfa consumer and producer for the above post
<endpoint id="callkafkaSuspenseProducer"
uri="kafka:${kafkaserver}?topic=SuspendedCdr3&zookeeperHost=${zookeeperHost}&zookeeperPort=${zookeeperport}&serializerClass=kafka.serializer.StringEncoder&producerType=sync"
/>
<endpoint id="callkafkaSuspenseConsumer"
uri="kafka:${kafkaserver}?topic=SuspendedCdr3&zookeeperHost=${zookeeperHost}&zookeeperPort=${zookeeperport}&serializerClass=kafka.serializer.StringEncoder&autoOffsetReset=smallest&groupId=default&consumerId=1"
/>
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-kakfa-Component-making-the-route-run-continously-infinitely-tp5800761p5800765.html
Sent from the Camel - Users mailing list archive at Nabble.com.