[fix][broker] Fix String wrong format (apache#21829)

(cherry picked from commit fd3d8b9)
datastax · Apr 15, 2024 · 3e3efe6 · 3e3efe6
1 parent 58a421a
commit 3e3efe6
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 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
@@ -826,7 +826,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);
 
@@ -1548,7 +1548,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
@@ -1267,7 +1267,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
@@ -2783,7 +2783,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);
@@ -2890,7 +2890,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);
@@ -3102,7 +3102,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/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java b/...roker/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/...ker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java b/...ker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -881,7 +881,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/.../apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java b/.../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);