[pulsar] branch branch-2.9 updated: [cherry-pick][branch-2.9] Fix race condition while updating partition number (#19199) (#19691)

[zhaocong]

This is an automated email from the ASF dual-hosted git repository.

zhaocong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.9 by this push:
     new 2f88e402a70 [cherry-pick][branch-2.9] Fix race condition while 
updating partition number (#19199) (#19691)
2f88e402a70 is described below

commit 2f88e402a706a8898f894b4414dadc702a217833
Author: Cong Zhao <zhaoc...@apache.org>
AuthorDate: Sat Mar 4 01:36:31 2023 +0800

    [cherry-pick][branch-2.9] Fix race condition while updating partition 
number (#19199) (#19691)
---
 .../java/org/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 8c5a17b45c9..e8ac4bb457d 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
@@ -3845,7 +3845,7 @@ public class PersistentTopicsBase extends AdminResource {
                         final String topicNamePartition = 
topicName.getPartition(i).toString();
 
                         
subscriptionFutures.add(admin.topics().createSubscriptionAsync(topicNamePartition,
-                                subscription, MessageId.latest));
+                                subscription, MessageId.earliest));
                     }
                 });