You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xy...@apache.org on 2023/11/17 11:47:44 UTC
(pulsar-client-cpp) 01/02: Log topic lookup result (#351)
This is an automated email from the ASF dual-hosted git repository.
xyz pushed a commit to branch branch-3.4
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
commit 806698ee50431d46a35d12c4ae7fbb913b419c81
Author: erobot <er...@users.noreply.github.com>
AuthorDate: Fri Nov 17 16:03:37 2023 +0800
Log topic lookup result (#351)
(cherry picked from commit c771b12fd564c9d7c351e61fa3ced56a8f15ec1f)
---
lib/BinaryProtoLookupService.cc | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/lib/BinaryProtoLookupService.cc b/lib/BinaryProtoLookupService.cc
index c8d6b76..87f02ea 100644
--- a/lib/BinaryProtoLookupService.cc
+++ b/lib/BinaryProtoLookupService.cc
@@ -83,7 +83,8 @@ auto BinaryProtoLookupService::findBroker(const std::string& address, bool autho
}
});
} else {
- LOG_DEBUG("Lookup response for " << topic << ", lookup-broker-url " << data->getBrokerUrl());
+ LOG_INFO("Lookup response for " << topic << ", lookup-broker-url " << data->getBrokerUrl()
+ << ", from " << cnx->cnxString());
if (data->shouldProxyThroughServiceUrl()) {
// logicalAddress is the proxy's address, we should still connect through proxy
promise->setValue({responseBrokerAddress, address});