You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xi...@apache.org on 2022/12/07 07:02:51 UTC

[pulsar] branch branch-2.10 updated: [fix][broker] Update the log print content of createSubscriptions (#18024)

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

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


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 70417272078 [fix][broker] Update the log print content of createSubscriptions (#18024)
70417272078 is described below

commit 70417272078acabb4ae83d1f979c8f193a648a5d
Author: HuangZeGui <hz...@126.com>
AuthorDate: Fri Oct 14 09:20:38 2022 +0800

    [fix][broker] Update the log print content of createSubscriptions (#18024)
    
    Co-authored-by: huangzegui <hu...@didiglobal.com>
    (cherry picked from commit 230e7dcc16c26ad1f9e8336871f9bb19b8fe286f)
---
 .../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 416d8e36c99..698da80265d 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
@@ -4242,7 +4242,7 @@ public class PersistentTopicsBase extends AdminResource {
                 });
 
                 FutureUtil.waitForAll(subscriptionFutures).thenRun(() -> {
-                    log.info("[{}] Successfully created new partitions {}", clientAppId(), topicName);
+                    log.info("[{}] Successfully created subscriptions on new partitions {}", clientAppId(), topicName);
                     result.complete(null);
                 }).exceptionally(ex -> {
                     log.warn("[{}] Failed to create subscriptions on new partitions for {}",