From 0c3139f98456fc366588c2fd0d2e7401f6430574 Mon Sep 17 00:00:00 2001
From: Kai Wang <kwang@streamnative.io>
Date: Wed, 16 Feb 2022 22:57:00 +0800
Subject: [PATCH] [Broker] Change broker producer fence log level (#14196)

(cherry picked from commit 141ea9b6dd3897d492cf468b6ded29ce9f7cf73f)
---
 .../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 04d3ab5b2e4e8..3871f213f216d 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
@@ -1283,8 +1283,15 @@ protected void handleProducer(final CommandProducer cmdProducer) {
 
                                         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)) {