GH-3078: Compute Seek Position from Current Offset #3099
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Fixes: spring-projects#3078 * Provide a new API method in `ConsumerSeekCallback` to seek to an offset based on the current offset. This is accomplished by a user-defined function where the user can make decision on the offset to seek to based on the current offset which is available via the function's input. * Adding tests, docs.
artembilan
requested changes
Mar 5, 2024
| @@ -49,6 +51,11 @@ void seekToTimestamp(String topic, int partition, long timestamp); | |||
| void seekToTimestamp(Collection<TopicPartition> topicPartitions, long timestamp); | |||
| ---- | |||
|
|
|||
| The two different variants of the `seek` methods provide a way to seek to an arbitrary offset. | |||
| The method that takes a `Function` as an argument to compute the offset was added in version `3.2` of the framework. | |||
There was a problem hiding this comment.
Our preference to not make just version number as a code.
| [[x32-seek-offset-compute-fn]] | ||
| === New API method to seek to an offset based on a user provided function | ||
| `ConsumerCallback` provides a new API to seek to an offset based on a user-defined function, which takes the current offset in the consumer as an argument. | ||
| See xref:kafka/seek.adoc#seek/[Seek API Docs] for more details. |
There was a problem hiding this comment.
I think that slash in the end of link is a mistake.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Fixes: #3078
ConsumerSeekCallbackto seek to an offset based on the current offset. This is accomplished by a user-defined function where the user can make decision on the offset to seek to based on the current offset which is available via the function's input.