[rocketmq] branch develop updated: comment fix

[jinrongtong]

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 fae6825  comment fix
     new ecdeb1b  Merge pull request #2039 from lebron374/comment_fix_v1
fae6825 is described below

commit fae6825f880ce592fc087cd86e8812482d68818a
Author: lebron374 <lebron...@163.com>
AuthorDate: Mon May 25 23:26:39 2020 +0800

    comment fix
---
 .../java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index e9c5286..5ccabb9 100644
--- 
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;