[pulsar] branch master updated: change topic lookup redirect log level (#7215)

[pe...@apache.org]

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

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 626f2c8  change topic lookup redirect log level (#7215)
626f2c8 is described below

commit 626f2c8f635d50d1abff1d942c9bc71a08004225
Author: hangc0276 <ha...@163.com>
AuthorDate: Tue Jun 9 16:33:00 2020 +0800

    change topic lookup redirect log level (#7215)
    
    Fix #7189
    
    Changes
    change the WebApplicationException log level from error to debug
---
 .../org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
index 908d3fa..afa4fe7 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -2624,6 +2624,11 @@ public class PersistentTopicsBase extends AdminResource {
         try {
             validateReadOperationOnTopic(authoritative);
             topic = getTopicReference(topicName);
+        } catch (WebApplicationException wae) {
+            log.debug("[{}] Failed to get last messageId {}, redirecting to other brokers.",
+                    clientAppId(), topicName, wae);
+            resumeAsyncResponseExceptionally(asyncResponse, wae);
+            return;
         } catch (Exception e) {
             log.error("[{}] Failed to get last messageId {}", clientAppId(), topicName, e);
             resumeAsyncResponseExceptionally(asyncResponse, e);