Merge pull request alibaba#2039 from lebron374/comment_fix_v1

[ISSUE alibaba#1971] Fix ConsumerFilterManager comment error
CST11021 · May 26, 2020 · ecdeb1b · ecdeb1b
2 parents 41ce16b + fae6825
commit ecdeb1b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java b/broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java
@@ -47,7 +47,7 @@ public class ConsumerFilterManager extends ConfigManager {
     private static final long MS_24_HOUR = 24 * 3600 * 1000;
 
     private ConcurrentMap<String/*Topic*/, FilterDataMapByTopic>
-        filterDataByTopic = new ConcurrentHashMap<String/*consumer group*/, FilterDataMapByTopic>(256);
+        filterDataByTopic = new ConcurrentHashMap<String/*Topic*/, FilterDataMapByTopic>(256);
 
     private transient BrokerController brokerController;
     private transient BloomFilter bloomFilter;