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 {