remove redundant placeholders (apache#12717)

eolivelli · Nov 29, 2021 · ce902d0 · ce902d0
1 parent 77ca28c
commit ce902d0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java
@@ -300,7 +300,7 @@ private void processPublishMessageResults(List<ProducerAck> produceMessageResult
                 produceMessageResults.get(index).setMessageId(messageId.toString());
             } catch (Exception e) {
                 if (log.isDebugEnabled()) {
-                    log.debug("Fail publish [{}] message with rest produce message request for topic  {}: {} ",
+                    log.debug("Fail publish [{}] message with rest produce message request for topic  {}",
                             index, topicName);
                 }
                 if (e instanceof BrokerServiceException.TopicNotFoundException) {

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -1338,7 +1338,7 @@ private CompletableFuture<Void> subscribeIncreasedTopicPartitions(String topicNa
                 return FutureUtil.failedFuture(new NotSupportedException("not support shrink topic partitions"));
             }
         }).exceptionally(throwable -> {
-            log.warn("[{}] Failed to get partitions for topic to determine if new partitions are added", throwable);
+            log.warn("Failed to get partitions for topic to determine if new partitions are added", throwable);
             return null;
         });
     }