You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/10/14 13:29:30 UTC
(pulsar) 06/06: [improve][broker] Add log to track issue when `handleGetTopicsOfNamespace` (#23434)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 26f4a400c0582ad5a78a097363729a52197767fa
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Mon Oct 14 19:19:05 2024 +0800
[improve][broker] Add log to track issue when `handleGetTopicsOfNamespace` (#23434)
(cherry picked from commit 33475ec456ad4f297d8c77bd33b76db38bc80cef)
---
.../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 b180d549f82..beef7819589 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
@@ -2390,8 +2390,8 @@ public class ServerCnx extends PulsarHandler implements TransportCnx {
filterTopics = true;
filteredTopics = TopicList.filterTopics(filteredTopics, topicsPattern.get());
} else {
- log.info("[{}] Subscription pattern provided was longer than maximum {}.",
- remoteAddress, maxSubscriptionPatternLength);
+ log.info("[{}] Subscription pattern provided [{}] was longer than maximum {}.",
+ remoteAddress, topicsPattern.get(), maxSubscriptionPatternLength);
}
}
String hash = TopicList.calculateHash(filteredTopics);