Sebastian Rühl created CAMEL-9716:
-------------------------------------
Summary: Camel KafkaConsumer should be able to re-consume the
Kafka stream.
Key: CAMEL-9716
URL: https://issues.apache.org/jira/browse/CAMEL-9716
Project: Camel
Issue Type: New Feature
Components: camel-kafka
Affects Versions: 2.17.0
Reporter: Sebastian Rühl
Priority: Minor
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
{code:java}
public void seekToBeginning(TopicPartition... partitions) {
{code}
{panel:title= Sidenode
|borderStyle=dashed|borderColor=#ccc|titleBGColor=#F7D6C1|bgColor=#FFFFCE}
There are other methods to manipulate offsets but for this ticket we just look
on the re-consume corner case.
{panel}
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
