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)) {