AW: Access native KafkaConsumer in Camel RoutePolicy

2020-08-24 Thread Burkard Stephan
: users@camel.apache.org Betreff: Re: Access native KafkaConsumer in Camel RoutePolicy Hi Stephan I recall you have used Camel a long time ago. About the pause/resume, then you are welcome to create a JIRA ticket so we can look at adding this API to camel-kafka consumer. From a route policy, you can

Re: Access native KafkaConsumer in Camel RoutePolicy

2020-08-24 Thread Claus Ibsen
Hi Stephan I recall you have used Camel a long time ago. About the pause/resume, then you are welcome to create a JIRA ticket so we can look at adding this API to camel-kafka consumer. >From a route policy, you can get hold on the consumer which you can cast to KafkaConsumer (Camel's) and then w

Access native KafkaConsumer in Camel RoutePolicy

2020-08-24 Thread Burkard Stephan
Hi **I also posted this question on StackOverflow** => https://stackoverflow.com/q/63519628/8035582 I "monitor" the number of consecutive failures in my Camel processing pipeline with a Camel RoutePolicy. When a threshold of failures is reached, I want to pause the processing for a configur