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 <[email protected]>
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);
