You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2026/01/26 09:31:25 UTC
(rocketmq) branch develop updated: [ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989)
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 <ya...@163.com>
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) {