rabbitmq / rabbitmq/rabbitmq-stream-java-client
Allow consumer to fast-forward
Nobody has claimed this yet.
- Dominant language
- Java
- Stars
- 72
- Forks
- 19
- Avg merge
- 6h 9m
- Merged PRs (30d)
- 32
Description
Messages in a stream can become useless at some point for an application, until another point in the stream. The application should be able to set an offset and get messages up to this point.
Provide an API (Context in MessageHandler or the Consumer interface itself) to fast-forward the subscription to a given offset.
See https://github.com/rabbitmq/rabbitmq-stream-java-client/discussions/78 for background.
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start by reading the Consumer interface and the Context available in MessageHandler, then review discussion 78 for the intended fast-forward semantics. Define how a consumer sets a target offset and receives messages only up to that point; done means the public API supports this behavior consistently.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- backend, distributed-systems
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100