This is an automated email from the ASF dual-hosted git repository.
mmarshall pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.8 by this push:
new 0c3139f [Broker] Change broker producer fence log level (#14196)
0c3139f is described below
commit 0c3139f98456fc366588c2fd0d2e7401f6430574
Author: Kai Wang <[email protected]>
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 04d3ab5..3871f21 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 @@ 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)) {
