BewareMyPower commented on issue #12888: URL: https://github.com/apache/pulsar/issues/12888#issuecomment-973906020
It looks like the C++ client has configured the URL redirection, see https://github.com/apache/pulsar/blob/b807200552117c299e3776e33537d082a00290d5/pulsar-client-cpp/lib/HTTPLookupService.cc#L182-L184 And it's weird that you log is ``` Error Code 22 ``` See https://curl.se/libcurl/c/libcurl-errors.html > CURLE_HTTP_RETURNED_ERROR (22) > > This is returned if CURLOPT_FAILONERROR is set TRUE and the HTTP server returns an error code that is >= 400. Could you try following C++ code and see what would happen? ```c++ #include <curl/curl.h> #include <iostream> #include <string> static size_t curlWriteCallback(void *contents, size_t size, size_t nmemb, void *responseDataPtr) { ((std::string *)responseDataPtr)->append((char *)contents, size * nmemb); return size * nmemb; } int main() { std::string completeUrl = "http://1.62.3.1:1001/lookup/v2/topic/persistent/pulsar-q4822m9k7ej8/test-ns/test-topic-1-partition-30";; std::string header = "Authorization: Bearer eyJrZXlJZCI6InB1bHNhci1xcccccxxxxx"; CURL *handle = curl_easy_init(); if (!handle) { return 1; } // set URL curl_easy_setopt(handle, CURLOPT_URL, completeUrl.c_str()); // Write callback std::string responseData; curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, curlWriteCallback); curl_easy_setopt(handle, CURLOPT_WRITEDATA, &responseData); // New connection is made for each call curl_easy_setopt(handle, CURLOPT_FRESH_CONNECT, 1L); curl_easy_setopt(handle, CURLOPT_FORBID_REUSE, 1L); // Skipping signal handling - results in timeouts not honored during the DNS // lookup curl_easy_setopt(handle, CURLOPT_NOSIGNAL, 1L); // Timer curl_easy_setopt(handle, CURLOPT_TIMEOUT, 3); // Set User Agent curl_easy_setopt(handle, CURLOPT_USERAGENT, "Pulsar-CPP-v2.8.0"); // Redirects curl_easy_setopt(handle, CURLOPT_FOLLOWLOCATION, 1L); curl_easy_setopt(handle, CURLOPT_MAXREDIRS, 20); // Fail if HTTP return code >=400 curl_easy_setopt(handle, CURLOPT_FAILONERROR, 1L); struct curl_slist *list = NULL; list = curl_slist_append(list, header.c_str()); curl_easy_setopt(handle, CURLOPT_HTTPHEADER, list); char errorBuffer[CURL_ERROR_SIZE]; curl_easy_setopt(handle, CURLOPT_ERRORBUFFER, errorBuffer); curl_easy_setopt(handle, CURLOPT_CUSTOMREQUEST, "GET"); auto res = curl_easy_perform(handle); std::cout << "Result: " << res << ", error: " << errorBuffer << std::endl; long httpResponseCode; curl_easy_getinfo(handle, CURLINFO_RESPONSE_CODE, &httpResponseCode); std::cout << "HTTP response code: " << httpResponseCode << std::endl; curl_easy_cleanup(handle); std::cout << "Content:\n" << responseData << std::endl; return 0; } ``` You need to modify `completeUrl` and `header` according to your URL. For example, in my local env, the output could be ``` Result: 0, error: HTTP response code: 200 Content: {"brokerUrl":"pulsar://localhost:6650","httpUrl":"http://localhost:8080","nativeUrl":"pulsar://localhost:6650","brokerUrlSsl":""} ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
