通过设置rondom=1来使主题其他broker也可以拉到重试队列消息

jd-opensource · Sep 7, 2020 · 55b44d7 · 55b44d7
1 parent 7d771cb
commit 55b44d7
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/.../joyqueue-broker-core/src/main/java/org/joyqueue/broker/consumer/CasPartitionManager.java b/.../joyqueue-broker-core/src/main/java/org/joyqueue/broker/consumer/CasPartitionManager.java
@@ -233,10 +233,6 @@ public boolean isRetry(Consumer consumer) throws JoyQueueException {
         } else if (!masterPartitionList.contains((short) 0)) {
             return false;
         }
-        /*if (!retry.booleanValue() || !masterPartitionList.contains((short) 0)) {
-            logger.debug("retry enable is false.");
-            return false;
-        }*/
 
         int val = random.nextInt(randomBound);
         // 重试管理中获取从重试分区消费的概率