Skip to content

[ISSUE #10114] Support delete consumer offset by consumer group and t…#10115

Open
echooymxq wants to merge 1 commit intoapache:developfrom
echooymxq:develop
Open

[ISSUE #10114] Support delete consumer offset by consumer group and t…#10115
echooymxq wants to merge 1 commit intoapache:developfrom
echooymxq:develop

Conversation

@echooymxq
Copy link
Contributor

Which Issue(s) This PR Fixes

Fixes #10114


RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr),
request, timeoutMillis);
assert response != null;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Using assert to check for null values ​​is not ideal. Users must add the JVM startup parameter -ea during configuration for it to take effect; otherwise, there is a risk of NPE errors.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Kris20030907 There are many similar issues in MQClientAPIImpl. We may need to open a separate issue for discussion.

Copy link
Contributor

@Kris20030907 Kris20030907 Feb 28, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yep, I think this is necessary; other projects have encountered similar issues in production environments.
cc.@RongtongJin

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Kris20030907 From your perspective, i'd like to ask whether this features is necessary for users. we have encountered many users with similar demands in the production environment.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is just an optimization point. Without adding the -ea parameter, the assert logic here will not take effect. People who are unaware of this feature might be misled when troubleshooting, because IDEA automatically adds this parameter, which may differ from the actual environment.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Kris20030907 The feature I'm referring to specifically is delete consumer offset.😂

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

got it, No users have raised this request yet, but I think it could be a good option.

Senrian pushed a commit to Senrian/rocketmq that referenced this pull request Feb 28, 2026
Signed-off-by: sen <sen@example.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Enhancement] Support delete consumer offset by consumer group and topic

2 participants