You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/10/12 05:10:46 UTC
[pulsar] branch branch-2.11 updated: [broker] ServerCnx: log at warning level when topic not found (#16225)
This is an automated email from the ASF dual-hosted git repository.
mmarshall pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new 429a81c8759 [broker] ServerCnx: log at warning level when topic not found (#16225)
429a81c8759 is described below
commit 429a81c875978d2abdf3b469a94aeb6ee4dd52e1
Author: Michael Marshall <mm...@apache.org>
AuthorDate: Tue Oct 11 22:06:01 2022 -0700
[broker] ServerCnx: log at warning level when topic not found (#16225)
### Motivation
In https://github.com/apache/pulsar/pull/13950, we switched an error log to an info log. @hsaputra requested on Pulsar Slack we use warn level so that alerts still fire in for the case when the topic is not found.
### Modifications
* Replace `info` with `warn` when topic is not found in the `ServerCnx` class.
- [x] `doc-not-needed`
(cherry picked from commit 72e044515d8dae3ce452818261b7328a4deb6e5f)
---
.../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 25bd769a8bf..18d6d11e122 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
@@ -1433,7 +1433,7 @@ public class ServerCnx extends PulsarHandler implements TransportCnx {
// Do not print stack traces for expected exceptions
if (cause instanceof NoSuchElementException) {
cause = new TopicNotFoundException("Topic Not Found.");
- log.info("[{}] Failed to load topic {}, producerId={}: Topic not found", remoteAddress, topicName,
+ log.warn("[{}] Failed to load topic {}, producerId={}: Topic not found", remoteAddress, topicName,
producerId);
} else if (!Exceptions.areExceptionsPresentInChain(cause,
ServiceUnitNotReadyException.class, ManagedLedgerException.class)) {