You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/27 00:55:46 UTC
[jira] [Commented] (CAMEL-10901) Add support to Kafka consumer to
seek to end of topic
[ https://issues.apache.org/jira/browse/CAMEL-10901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884990#comment-15884990 ]
ASF GitHub Bot commented on CAMEL-10901:
----------------------------------------
GitHub user sverkera opened a pull request:
https://github.com/apache/camel/pull/1495
CAMEL-10901 Implemented support for Kafka consumer to seek to either ...
… beginning or end of topic on startup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sverkera/camel master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/camel/pull/1495.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1495
----
commit e00cd5db25a62621e463d5aa7a17ed5405e2ded5
Author: Sverker Abrahamsson <sv...@limetransit.com>
Date: 2017-02-27T00:08:14Z
CAMEL-10901 Implemented support for Kafka consumer to seek to end of topic on startup
----
> Add support to Kafka consumer to seek to end of topic
> -----------------------------------------------------
>
> Key: CAMEL-10901
> URL: https://issues.apache.org/jira/browse/CAMEL-10901
> Project: Camel
> Issue Type: New Feature
> Components: camel-kafka
> Affects Versions: 2.19.0
> Reporter: Sverker Abrahamsson
> Priority: Minor
>
> Kafka 2.19.0-SNAPSHOT adds seekToBeginning parameter to read all events of a topic from beginning. In my application I'm not interested of what has happened before it is started, so I need the opposite so that seekToEnd is called on the consumer.
> The pull request for this feature request will change the parameter to seekTo which can be set to either beginning or end, which is analog with how other parameters on this consumer is set.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)