You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rg...@apache.org on 2022/03/01 16:24:13 UTC
[pulsar] 04/21: [Broker] Change broker producer fence log level (#14196)
This is an automated email from the ASF dual-hosted git repository.
rgao pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c16083e95a9c3407860a00c7cabe2d0db2708347
Author: Kai Wang <kw...@streamnative.io>
AuthorDate: Wed Feb 16 22:57:00 2022 +0800
[Broker] Change broker producer fence log level (#14196)
(cherry picked from commit 141ea9b6dd3897d492cf468b6ded29ce9f7cf73f)
---
.../main/java/org/apache/pulsar/broker/service/ServerCnx.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
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 beb713c..2ba51d2 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
@@ -1335,8 +1335,15 @@ public class ServerCnx extends PulsarHandler implements TransportCnx {
producers.remove(producerId, producerFuture);
}).exceptionally(ex -> {
- log.error("[{}] Failed to add producer to topic {}: producerId={}, {}",
- remoteAddress, topicName, producerId, ex.getMessage());
+ if (ex.getCause() instanceof BrokerServiceException.ProducerFencedException) {
+ if (log.isDebugEnabled()) {
+ log.debug("[{}] Failed to add producer to topic {}: producerId={}, {}",
+ remoteAddress, topicName, producerId, ex.getCause().getMessage());
+ }
+ } else {
+ log.warn("[{}] Failed to add producer to topic {}: producerId={}, {}",
+ remoteAddress, topicName, producerId, ex.getCause().getMessage());
+ }
producer.closeNow(true);
if (producerFuture.completeExceptionally(ex)) {