You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Willem Jiang (JIRA)" <ji...@apache.org> on 2015/04/17 03:52:58 UTC

[jira] [Created] (CAMEL-8653) camel-kafka need to commit the last batch offset when shutdown the consumer

Willem Jiang created CAMEL-8653:
-----------------------------------

             Summary: camel-kafka need to commit the last batch offset when shutdown the consumer
                 Key: CAMEL-8653
                 URL: https://issues.apache.org/jira/browse/CAMEL-8653
             Project: Camel
          Issue Type: Improvement
          Components: camel-kafka
    Affects Versions: 2.15.1, 2.15.0
            Reporter: Willem Jiang
            Priority: Minor
             Fix For: 2.15.2, 2.16.0



Fix of CAMEL-8636 would solve the scenario of when Kafka Broker is shutdown. 

Client shutdown scenario still results in un-committed offsets from the last batch. 
For this situation, Offset needs to be commited just before the *Customer* shutdown. Meanwhile some lock mechanism needs to be built with Shutdown hook that would do the following: 
* Block messages from getting consumed from kafka 
* Wait for all the messages that are getting processed to be completed. 
* Commit the Offset 
* Shutdown the Cosumer



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