This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new fd3d8b9298b [fix][broker] Fix String wrong format (#21829)
fd3d8b9298b is described below
commit fd3d8b9298b13c82bc2bca2149211a865b41ee88
Author: Jiwe Guo <[email protected]>
AuthorDate: Mon Feb 5 16:30:04 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 | 6 +++---
.../pulsar/broker/service/persistent/PersistentReplicator.java | 2 +-
.../pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
.../buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java | 2 +-
6 files changed, 9 insertions(+), 9 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 fcf1a2a2010..ef37aec6001 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
@@ -820,7 +820,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);
@@ -1541,7 +1541,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 f7cd161b9e8..a768beacde1 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
@@ -1266,7 +1266,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 780537b9cb0..62493fdafa9 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
@@ -2829,7 +2829,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);
@@ -2936,7 +2936,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);
@@ -3108,7 +3108,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 0b341524339..0c3c9d63ad1 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
@@ -532,7 +532,7 @@ public abstract 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 973093bb0a8..b4c089a227e 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
@@ -860,7 +860,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);
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
index 258a253c12e..4f85270be95 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
@@ -325,7 +325,7 @@ public class SnapshotSegmentAbortedTxnProcessorImpl
implements AbortedTxnProcess
@Override
public String toString() {
- return
String.format("Transaction buffer [{}] recover from snapshot",
+ return
String.format("Transaction buffer [%s] recover from snapshot",
SnapshotSegmentAbortedTxnProcessorImpl.this.topic.getName());
}
}, null);
