You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2022/03/27 12:38:18 UTC
[pulsar] branch branch-2.8 updated: ServerCnx] Improve error logging for topic not found (#13950) (#14892)
This is an automated email from the ASF dual-hosted git repository.
eolivelli 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 4425725 ServerCnx] Improve error logging for topic not found (#13950) (#14892)
4425725 is described below
commit 44257253969470b94909a64984a72205ea9a430e
Author: gaozhangmin <ga...@gmail.com>
AuthorDate: Sun Mar 27 20:36:29 2022 +0800
ServerCnx] Improve error logging for topic not found (#13950) (#14892)
* [ServerCnx] Improve error logging for topic not found
* Log topic not found at INFO level
(cherry picked from commit 54c898f18bf8c53d64c7f87049bb63764137acb0)
Co-authored-by: Michael Marshall <mm...@apache.org>
---
.../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java | 6 +++---
1 file changed, 3 insertions(+), 3 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 3871f21..1a0be5e 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
@@ -1317,9 +1317,9 @@ public class ServerCnx extends PulsarHandler implements TransportCnx {
if (cause instanceof NoSuchElementException) {
cause = new TopicNotFoundException("Topic Not Found.");
- }
-
- if (!Exceptions.areExceptionsPresentInChain(cause,
+ log.info("[{}] Failed to load topic {}, producerId={}: Topic not found",
+ remoteAddress, topicName, producerId);
+ } else if (!Exceptions.areExceptionsPresentInChain(cause,
ServiceUnitNotReadyException.class, ManagedLedgerException.class)) {
// Do not print stack traces for expected exceptions
log.error("[{}] Failed to create topic {}, producerId={}",