This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b6ae15796e01d9137066c39d7d7dd6885a49a9d7 Author: gaozhangmin <[email protected]> AuthorDate: Mon Nov 15 08:53:09 2021 +0800 remove redundant placeholders (#12717) (cherry picked from commit 4fac93cf0a6a0f41c0674691f108f14af74be1b8) --- .../src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java | 2 +- .../java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java | 2 +- 2 files changed, 2 insertions(+), 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 index 76ce022..8151a82 100644 --- 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 @@ public class TopicsBase extends PersistentTopicsBase { 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 index 2c356fb..09dc5643 100644 --- 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 @@ -1328,7 +1328,7 @@ public class MultiTopicsConsumerImpl<T> extends ConsumerBase<T> { 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; }); }
