[
https://issues.apache.org/jira/browse/CAMEL-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sebastian Rühl updated CAMEL-9716:
----------------------------------
Attachment:
_CAMEL_9716__call_wakeup_on_kafka_consumer_to_enforce_shutdown.patch
this patch is separated from the pull request as it integrates some advanced
shutdown that needs review before it can be integrated into the PR. Also this
one makes the jUnit test run proper.
> 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
> Attachments:
> _CAMEL_9716__call_wakeup_on_kafka_consumer_to_enforce_shutdown.patch
>
>
> 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)
