apache / apache/rocketmq-externals
[rocketmq-spark] consuming message repeatly when app restarts,
Open
- Dominant language
- Java
- Stars
- 4.6k
- Forks
- 3k
- Avg merge
- 2h 33m
- Merged PRs (30d)
- 1
Description
What are the considerations for the offset minus one when commit offset?
Contributor guide
No contributing guide indexed for this repository
Research direction
Start with the rocketmq-spark consumer and its offset-commit handling, then reproduce the repeated message consumption after an application restart. Trace why the committed offset is decremented by one and determine the expected restart behavior. Done means the offset semantics are understood and restarting the application no longer causes unintended repeated consumption.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Active
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100