[SLING-11028] Support relative offsets

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: Content Distribution Journal Messages 0.3.0
• Fix Version/s: Content Distribution Journal Kafka 0.3.0, Content Distribution Journal Messages 0.4.0
• Component/s: Content Distribution
• Assignee: Christian Schneider
• Reporter: Christian Schneider
• Created: 20/Dec/21 12:42
• Updated: 03/Jan/22 13:26
• Resolved: 03/Jan/22 13:26

Description

In some cases it is necessary to specify the offset to start from not absolutely but relative to earliest or latest of the topic partition.

This change introduces MessagingProvider.assignTo(Reset reset, long relativeOffset). This for example allows to start by rereading the latest message using:

assignTo(Reset.latest, -1)

 

Issue Links

• links to: GitHub Pull Request #8
• links to: GitHub Pull Request #10