You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2024/01/22 14:57:03 UTC
(pulsar) branch branch-2.10 updated: [fix][broker] Fix String wrong format (#21829)
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 1b24289d6b9 [fix][broker] Fix String wrong format (#21829)
1b24289d6b9 is described below
commit 1b24289d6b9e9988381f6ad1cc61a213d39e404a
Author: Jiwe Guo <te...@apache.org>
AuthorDate: Mon Jan 22 22:56:47 2024 +0800
[fix][broker] Fix String wrong format (#21829)
---
.../java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 ++--
.../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +-
.../org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java | 4 ++--
.../apache/pulsar/broker/service/persistent/PersistentReplicator.java | 2 +-
.../pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
index d609d91b842..8867d81cb1b 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
@@ -753,7 +753,7 @@ public class ManagedCursorImpl implements ManagedCursor {
@Override
public String toString() {
- return String.format("Cursor [{}] get Nth entry", ManagedCursorImpl.this);
+ return String.format("Cursor [%s] get Nth entry", ManagedCursorImpl.this);
}
}, null);
@@ -1438,7 +1438,7 @@ public class ManagedCursorImpl implements ManagedCursor {
@Override
public String toString() {
- return String.format("Cursor [{}] async replay entries", ManagedCursorImpl.this);
+ return String.format("Cursor [%s] async replay entries", ManagedCursorImpl.this);
}
};
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
index c2239953c50..0515fd21131 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
@@ -1239,7 +1239,7 @@ public class ManagedLedgerImpl implements ManagedLedger, CreateCallback {
@Override
public String toString() {
- return String.format("ML [{}] get earliest message publish time of pos",
+ return String.format("ML [%s] get earliest message publish time of pos",
ManagedLedgerImpl.this.name);
}
}, null);
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 f18f30a8606..867f45a5e3c 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
@@ -2568,7 +2568,7 @@ public class PersistentTopicsBase extends AdminResource {
@Override
public String toString() {
- return String.format("Topic [{}] get entry batch size",
+ return String.format("Topic [%s] get entry batch size",
PersistentTopicsBase.this.topicName);
}
}, null);
@@ -2660,7 +2660,7 @@ public class PersistentTopicsBase extends AdminResource {
@Override
public String toString() {
- return String.format("Topic [{}] internal get message by id",
+ return String.format("Topic [%s] internal get message by id",
PersistentTopicsBase.this.topicName);
}
}, null);
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
index 1f47cdecb16..4de9dec1717 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
@@ -656,7 +656,7 @@ public class PersistentReplicator extends AbstractReplicator
@Override
public String toString() {
- return String.format("Replication [{}] peek Nth message",
+ return String.format("Replication [%s] peek Nth message",
PersistentReplicator.this.producer.getProducerName());
}
}, null);
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
index fe74910be41..a546113318c 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -738,7 +738,7 @@ public class PersistentSubscription extends AbstractSubscription implements Subs
@Override
public String toString() {
- return String.format("Subscription [{}-{}] async replay entries", PersistentSubscription.this.topicName,
+ return String.format("Subscription [%s-%s] async replay entries", PersistentSubscription.this.topicName,
PersistentSubscription.this.subName);
}
}, null);