[pulsar] branch branch-2.10 updated: [broker] ServerCnx: log at warning level when topic not found (#16225)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmarshall pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 58dfefc7bc0 [broker] ServerCnx: log at warning level when topic not found (#16225)
58dfefc7bc0 is described below

commit 58dfefc7bc0c3870c6f190508a69897526d2e787
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 979ae959936..7d9f2fc95b1 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
@@ -1376,7 +1376,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)) {