Skip to content

Commit 9ad4a1b

Browse files
authored
[ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989)
1 parent c7892a6 commit 9ad4a1b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ protected RemotingCommand getConsumerListByGroup(ChannelHandlerContext ctx, Remo
9494

9595
protected RemotingCommand getConsumerConnectionList(ChannelHandlerContext ctx, RemotingCommand request,
9696
ProxyContext context) throws Exception {
97-
RemotingCommand response = RemotingCommand.createResponseCommand(GetConsumerConnectionListRequestHeader.class);
97+
RemotingCommand response = RemotingCommand.createResponseCommand(null);
9898
GetConsumerConnectionListRequestHeader header = (GetConsumerConnectionListRequestHeader) request.decodeCommandCustomHeader(GetConsumerConnectionListRequestHeader.class);
9999
ConsumerGroupInfo consumerGroupInfo = messagingProcessor.getConsumerGroupInfo(context, header.getConsumerGroup());
100100
if (consumerGroupInfo != null) {

0 commit comments

Comments
 (0)