From c930a84c5ef5152d7bc1fb15bdd8e606186a522c Mon Sep 17 00:00:00 2001
From: mattisonchao <mattisonchao@apache.org>
Date: Thu, 12 Jan 2023 12:06:35 +0800
Subject: [PATCH] [fix][broker] Fix race condition while update parition number

---
 .../apache/pulsar/broker/admin/impl/PersistentTopicsBase.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 4d2ff1db3cf38..ed83e172d48f3 100644
--- 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 {