[ISSUE #9352] Fix wrong value in topic-group cache (#9424)

Author: golden-yang

broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java

@@ -241,7 +241,7 @@ public boolean registerConsumer(final String group, final ClientChannelInfo clie
                 Set<String> prev = this.topicGroupTable.putIfAbsent(subscriptionData.getTopic(), tmp);
                 groups = prev != null ? prev : tmp;
             }
-            groups.add(subscriptionData.getTopic());
+            groups.add(group);
         }
 
         boolean r1 =

broker/src/test/java/org/apache/rocketmq/broker/client/ConsumerManagerTest.java

@@ -17,6 +17,7 @@
 
 package org.apache.rocketmq.broker.client;
 
+import com.google.common.collect.ImmutableSet;
 import io.netty.channel.Channel;
 import org.apache.rocketmq.broker.BrokerController;
 import org.apache.rocketmq.broker.filter.ConsumerFilterManager;
@@ -179,6 +180,7 @@ public void queryTopicConsumeByWhoTest() {
         register();
         final HashSet<String> consumeGroup = consumerManager.queryTopicConsumeByWho(TOPIC);
         assertFalse(consumeGroup.isEmpty());
+        assertThat(consumerManager.queryTopicConsumeByWho(TOPIC)).isEqualTo(ImmutableSet.of(GROUP));
     }
 
     @Test