This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new b534ba5615e Fix String wrong format (#21829)
b534ba5615e is described below
commit b534ba5615e1219116b372a6f5bf5f9da9a6f656
Author: Jiwe Guo <[email protected]>
AuthorDate: Mon Jan 22 21:57:12 2024 +0800
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 | 6 +++---
.../pulsar/broker/service/persistent/PersistentReplicator.java | 2 +-
.../pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
5 files changed, 8 insertions(+), 8 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 6216fcda73d..eec133b829a 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
@@ -754,7 +754,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);
@@ -1460,7 +1460,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 4a021085f9c..ac3375e73cc 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
@@ -1246,7 +1246,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 f1bf96b8766..264bebfe50e 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
@@ -2703,7 +2703,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);
@@ -2795,7 +2795,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);
@@ -2970,7 +2970,7 @@ public class PersistentTopicsBase extends AdminResource {
@Override
public String toString() {
- return String.format("Topic [{}] internal
examine message async",
+ return String.format("Topic [%s] internal
examine message async",
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 3e1120ddc09..7e5b837b219 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 9dff986f45d..9c0bb77479c 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
@@ -852,7 +852,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);