[CAMEL-16949] camel-kafka: investigate alternatives to remove Thread.sleep from the record fetcher

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.12.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Otavio Rodolfo Piske
• Reporter: Otavio Rodolfo Piske
• Created: 13/Sep/21 09:15
• Updated: 20/Sep/21 18:03
• Resolved: 16/Sep/21 06:51

Description

The record fetch is using Thread.sleep. I think it would be good to investigate if we can replace that with a more elegant mechanism.

• https://github.com/apache/camel/blob/c0def695648fe93623d393950f8c06f8c526630f/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java#L97

 

 

Issue Links

• is required by: CAMEL-16973 camel-kafka: commits may be skipped on stop or shutdown
• is required by: CAMEL-16974 camel-kafka: make the resume strategy configurable
• links to: GitHub Pull Request #6093
• links to: GitHub Pull Request #6122