[CAMEL-9716] Camel KafkaConsumer should be able to re-consume the Kafka stream.

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.17.0
• Fix Version/s: 2.18.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Sebastian Rühl
• Created: 16/Mar/16 14:03
• Updated: 27/Feb/17 09:55
• Resolved: 27/Feb/17 09:55

Description

In some corner cases we should be able to re-consume a Kafka stream from the beginning on startup of the endpoint.
For this the Kafka-KafkaConsumer has a method

   public void seekToBeginning(TopicPartition... partitions) {

Sidenode

There are other methods to manipulate offsets but for this ticket we just look on the re-consume corner case.

Currently I have implemented this support in a branch here (https://github.com/sruehl/camel/tree/feature/kafka-seek-support) and have also written an jUnit test.
At this time this test still fails for unknown reasons.

I would be keen on some feedback on this feature and also would like to advance this branch to make it mergable.

Issue Links

• is related to: KAFKA-3458 Selector should throw InterruptException when interrupted