Zachariah Young created CAMEL-17051:
---------------------------------------

             Summary: Need the ability to pause kafka consumer
                 Key: CAMEL-17051
                 URL: https://issues.apache.org/jira/browse/CAMEL-17051
             Project: Camel
          Issue Type: New Feature
          Components: camel-kafka
    Affects Versions: 3.12.0
            Reporter: Zachariah Young
             Fix For: Future


When handling transient errors that have exhausted retry limits, sometimes 
pausing the Kafka consumer is the best way to handle an outage.  A great 
example of this would be the Facebook outage that happen this week.

One might suggest that stopping the consumer work would for this use case.  
This would of course work but would require a manual restart.  Also, you want 
to try to avoid a rebalance of the consumer.

I would like to see a new strategy be created that would allow for pause and 
resume to be configured.

Ideally, the resume could be configured based on a health check.

 

Example code: 
[https://github.com/jeanlouisboudart/retriable-consumer/blob/master/consumer/src/main/java/com/sample/InfiniteRetriesConsumer.java]

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to