jd-opensource / jd-opensource/joyqueue
并行消费问题
Open
Nobody has claimed this yet.
- Dominant language
- Java
- Stars
- 383
- Forks
- 139
- PR merge metrics
- No merged PRs in 30d
Description
开启并行消费，例如窗口大小5，批量大小默认10，消费一段时间后，如果主题生产者停止发送消息后，消费会立刻停止，一直卡住不消费，直到如果后续生产继续那么消费也会开始消费，可以进行反复操作复现该问题。
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 reproducing the issue with parallel consumption window 5 and the default batch size of 10, then inspect the consumer path that runs after the producer stops sending messages. The work is done when consumption does not remain stuck during producer inactivity and a regression test covers stopping and resuming production.
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
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100