This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 9ad4a1b947 [ISSUE #9988] Remove mismatched response header in
getConsumerConnectionList (#9989)
9ad4a1b947 is described below
commit 9ad4a1b94719aa39fd1f1569d739f9978885dc63
Author: yx9o <[email protected]>
AuthorDate: Mon Jan 26 17:31:20 2026 +0800
[ISSUE #9988] Remove mismatched response header in
getConsumerConnectionList (#9989)
---
.../rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java
index b21b4afa42..ce1f1b4a51 100644
---
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java
+++
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java
@@ -94,7 +94,7 @@ public class ConsumerManagerActivity extends
AbstractRemotingActivity {
protected RemotingCommand getConsumerConnectionList(ChannelHandlerContext
ctx, RemotingCommand request,
ProxyContext context) throws Exception {
- RemotingCommand response =
RemotingCommand.createResponseCommand(GetConsumerConnectionListRequestHeader.class);
+ RemotingCommand response = RemotingCommand.createResponseCommand(null);
GetConsumerConnectionListRequestHeader header =
(GetConsumerConnectionListRequestHeader)
request.decodeCommandCustomHeader(GetConsumerConnectionListRequestHeader.class);
ConsumerGroupInfo consumerGroupInfo =
messagingProcessor.getConsumerGroupInfo(context, header.getConsumerGroup());
if (consumerGroupInfo != null) {
