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

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


The following commit(s) were added to refs/heads/branch-4.1 by this push:
     new 3aa3301f747 [improve][broker] Optimize lookup result warn log (#24942)
3aa3301f747 is described below

commit 3aa3301f7478dc2ebc4919527e1899ce5d4e3ac5
Author: Baodi Shi <[email protected]>
AuthorDate: Tue Nov 4 19:04:09 2025 +0800

    [improve][broker] Optimize lookup result warn log (#24942)
    
    (cherry picked from commit 928cae2522a5076a56279ec912cb9e8baf9e3784)
---
 .../main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
index d0e913356b6..e89ae6bc99d 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
@@ -327,6 +327,10 @@ public class TopicLookupBase extends PulsarWebResource {
         if (!pulsar.getBrokerService().isSystemTopic(topic)) {
             return;
         }
+        if 
(SystemTopicNames.TRANSACTION_COORDINATOR_ASSIGN.getPartitionedTopicName()
+                .equals(topic.getPartitionedTopicName())) {
+            return;
+        }
         boolean tlsEnabled = pulsar.getConfig().isBrokerClientTlsEnabled();
         if (!tlsEnabled && StringUtils.isBlank(lookupData.getBrokerUrl())) {
             log.warn("[{}] Unexpected lookup result: brokerUrl is required 
when TLS isn't enabled. options: {},"

Reply via email to