Merge 7ae6caf into 0e43444

apache · Nov 4, 2022 · 9fc2179 · 9fc2179
2 parents 0e43444 + 7ae6caf
commit 9fc2179
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
@@ -374,6 +374,7 @@ private boolean updateProcessQueueTableInRebalance(final String topic, final Set
 
                 this.removeDirtyOffset(mq);
                 ProcessQueue pq = new ProcessQueue();
+                pq.setLocked(true);
 
                 long nextOffset = -1L;
                 try {