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 <darwinanir...@gmail.com> wrote:
> Kakfa consumer and producer for the above post
>
>         <endpoint id="callkafkaSuspenseProducer"
>
> uri="kafka:${kafkaserver}?topic=SuspendedCdr3&amp;zookeeperHost=${zookeeperHost}&amp;zookeeperPort=${zookeeperport}&amp;serializerClass=kafka.serializer.StringEncoder&amp;producerType=sync"
> />
>
>                 <endpoint id="callkafkaSuspenseConsumer"
>
> uri="kafka:${kafkaserver}?topic=SuspendedCdr3&amp;zookeeperHost=${zookeeperHost}&amp;zookeeperPort=${zookeeperport}&amp;serializerClass=kafka.serializer.StringEncoder&amp;autoOffsetReset=smallest&amp;groupId=default&amp;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

Reply via email to