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 fb77f1de624c3..060138f491e2f 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 @@ -824,7 +824,7 @@ public void readEntryComplete(Entry entry, Object ctx) { @Override public String toString() { - return String.format("Cursor [{}] get Nth entry", ManagedCursorImpl.this); + return String.format("Cursor [%s] get Nth entry", ManagedCursorImpl.this); } }, null); @@ -1544,7 +1544,7 @@ public synchronized void readEntryFailed(ManagedLedgerException mle, Object ctx) @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 8ce2a6924ebed..4084d7004a80d 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 @@ -1265,7 +1265,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) { @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 787ffe397de05..f3096b4a93f96 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 @@ -2740,7 +2740,7 @@ public void readEntryComplete(Entry entry, Object ctx) { @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); @@ -2844,7 +2844,7 @@ public void readEntryComplete(Entry entry, Object ctx) { @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); @@ -3016,7 +3016,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) { @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/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java index 9f2b98aeb40d9..467345e2c31c2 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java @@ -2227,7 +2227,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) { @Override public String toString() { - return String.format("ServerCnx [{}] get largest batch index when possible", + return String.format("ServerCnx [%s] get largest batch index when possible", ServerCnx.this.ctx.channel()); } }, 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 a4ac52d5ded7d..754d25b8b0ab4 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 @@ -533,7 +533,7 @@ public void readEntryComplete(Entry entry, Object ctx) { @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 812747860456c..1baa4087e5571 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 @@ -887,7 +887,7 @@ public void readEntryComplete(Entry entry, Object ctx) { @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 04b2ef66d25da..385500dfbe9e7 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 @@ -330,7 +330,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) { @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);