apache / apache/rocketmq

KeyBuilder strips retry topics for a different consumer group

Open Beginner friendly
#10,836 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
22.6k
Forks
12k
Avg merge
3d 1h
Merged PRs (30d)
27

Description

KeyBuilder.parseNormalTopic(topic, cid) strips every topic beginning with the retry prefix. If the topic belongs to another consumer group, it removes a prefix using the requested cid length and returns a corrupted topic; short regular retry topics can also throw. Expected behavior: strip only an exact POP retry prefix for the supplied consumer group.

Contributor guide

Open the contributing guide

Research direction

Search for KeyBuilder.parseNormalTopic(topic, cid) and inspect how it recognizes retry topics and uses the consumer-group id. Add focused coverage for a different consumer group and a short regular retry topic, then verify that only an exact POP retry prefix for the supplied group is stripped.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
distributed-systems
Issue type
Bug
Difficulty
2/5
Estimated time
1-3 hours
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
72/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.