[jira] [Commented] (CAMEL-9823) Exploring Consumer groups feature in Camel-kafka consumer side

[Anbumani Balusamy (JIRA)]

    [ 
https://issues.apache.org/jira/browse/CAMEL-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263688#comment-15263688
 ] 

Anbumani Balusamy commented on CAMEL-9823:
------------------------------------------

[~ancosen],

  We are already using consumerLoop logic in dostart(). please find the code. 

 @Override
    protected void doStart() throws Exception {
        super.doStart();
        LOG.info("Starting Kafka consumer");
        executor = endpoint.createExecutor();
        for (int i = 0; i < endpoint.getConsumersCount(); i++) {
            executor.submit(new KafkaFetchRecords(endpoint.getTopic(), i + "", 
getProps()));
        }
    }

Thanks!
Anbu

> Exploring Consumer groups feature in Camel-kafka consumer side
> --------------------------------------------------------------
>
>                 Key: CAMEL-9823
>                 URL: https://issues.apache.org/jira/browse/CAMEL-9823
>             Project: Camel
>          Issue Type: New Feature
>          Components: camel-kafka
>            Reporter: Andrea Cosentino
>            Assignee: Andrea Cosentino
>             Fix For: 2.18.0
>
>         Attachments: KafkaConsumer.java
>
>
> I guess we can take advantage from consumer groups feature in camel-kafka.
> http://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0.9-consumer-client



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)