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.

Reply via email to