[Bug] Proxy getConsumerListByGroup NPEs when consumer group is offline

Open Beginner friendly
#10,793 2 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty
2/5
Estimated time
1-3 hours
Newbie friendliness
75/100
Issue type
Bug
Clarity
Clearly specified
Activity status
Quiet
Tech stack
java
Domain
api, backend

Research direction

Start at ConsumerManagerActivity.getConsumerListByGroup and inspect how it uses messagingProcessor.getConsumerGroupInfo(...). Compare its offline-group handling with getConsumerConnectionList, then verify that an offline group returns CONSUMER_NOT_ONLINE with a clear remark instead of causing an internal error.

Written by the indexing model from the issue text.

Description

What happened?

ConsumerManagerActivity.getConsumerListByGroup calls messagingProcessor.getConsumerGroupInfo(...) and immediately dereferences the returned ConsumerGroupInfo. When the requested group is not online, the processor can return null, causing a NullPointerException.

getConsumerConnectionList in the same activity already handles this case by returning CONSUMER_NOT_ONLINE, so the two client-management queries currently have inconsistent behavior.

Why this matters

The Proxy client-management path is part of the Studio/Proxy Admin foundation. Querying online consumers for an offline group should return a deterministic client-facing response instead of an internal error.

Expected behavior

GET_CONSUMER_LIST_BY_GROUP should return CONSUMER_NOT_ONLINE with a clear remark when the group is not online.

Scope

RocketMQ Studio track 2 / Proxy client-management hardening.

Dominant language
Java
Stars
22.6k
Forks
12k
Avg merge
3d 12h
Merged PRs (30d)
25

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

More from apache/rocketmq

All issues in apache/rocketmq

Similar issues

More Java issues

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.