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

[mmarshall]

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 <mmarsh...@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)) {