This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 3dbfb68 Fixed Lookup redirect logic on Proxy side (#1265) 3dbfb68 is described below commit 3dbfb686bc699cb7a9a7c2eaa1cd364db3cd5c51 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed Feb 21 08:37:15 2018 -0800 Fixed Lookup redirect logic on Proxy side (#1265) --- .../main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java index 5c6951a..abf80e8 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java @@ -126,7 +126,7 @@ public class LookupProxyHandler { String brokerUrl = connectWithTLS ? result.brokerUrlTls : result.brokerUrl; if (result.redirect) { // Need to try the lookup again on a different broker - performLookup(clientRequestId, topic, brokerUrl, authoritative, numberOfRetries - 1); + performLookup(clientRequestId, topic, brokerUrl, result.authoritative, numberOfRetries - 1); } else { // Reply the same address for both TLS non-TLS. The reason is that whether we use TLS // between proxy -- To stop receiving notification emails like this one, please contact mme...@apache.org.