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 d0e913356b612..e89ae6bc99d62 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 @@ private static void printWarnLogIfLookupResUnexpected(TopicName topic, LookupDat 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: {},"