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

apache · Jan 2, 2024 · 529e1ab · 529e1ab
1 parent 200c925
commit 529e1ab
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 10 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
@@ -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
@@ -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
@@ -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
@@ -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/...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
@@ -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/.../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);