[fix][broker] Fix race condition while updating partition number (apa…

…che#19199)
teaey · Jan 12, 2023 · 4d57828 · 4d57828
1 parent a93f30f
commit 4d57828
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -4446,7 +4446,7 @@ private CompletableFuture<Void> createSubscriptions(TopicName topicName, int exp
                     final String topicNamePartition = topicName.getPartition(i).toString();
                     CompletableFuture<Void> future = new CompletableFuture<>();
                     admin.topics().createSubscriptionAsync(topicNamePartition,
-                                    subscription, MessageId.latest, replicated).whenComplete((__, ex) -> {
+                                    subscription, MessageId.earliest, replicated).whenComplete((__, ex) -> {
                         if (ex == null) {
                             future.complete(null);
                         } else {