Merge pull request #10 from uber-common/fix-T24893

Fix T248934
This commit is contained in:
Xiang Fu 2015-12-18 16:11:39 -08:00
commit 6e34031598

View File

@ -44,6 +44,7 @@ function KafkaRestClient(options, callback) {
self.connecting = false;
self.proxyHost = options.proxyHost;
self.urlToHttpClientMapping = {};
self.cachedTopicToUrlMapping = {};
self.proxyPort = options.proxyPort;
self.requestUrl = self.proxyHost + ':' + self.proxyPort;
self.mainHttpClient = new lbPool.Pool(http, [self.requestUrl], {