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 30fee6b Standalone bookie should always advertise 'localhost' when
running in docker container (#2425)
30fee6b is described below
commit 30fee6bb2f83e344dd2e86b675671762a9242f26
Author: Matteo Merli <[email protected]>
AuthorDate: Fri Aug 24 12:55:12 2018 -0700
Standalone bookie should always advertise 'localhost' when running in
docker container (#2425)
* Standalone bookie should always advertise 'localhost' when running in
docker container
* Fixed advertised address coming from config file
---
pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
index 3e44f76..cf07d8c 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
@@ -253,7 +253,8 @@ public class PulsarStandalone implements AutoCloseable {
if (!this.isOnlyBroker()) {
// Start LocalBookKeeper
bkEnsemble = new LocalBookkeeperEnsemble(
- this.getNumOfBk(), this.getZkPort(), this.getBkPort(),
this.getStreamStoragePort(), this.getZkDir(), this.getBkDir(),
this.isWipeData(), config.getAdvertisedAddress());
+ this.getNumOfBk(), this.getZkPort(), this.getBkPort(),
this.getStreamStoragePort(), this.getZkDir(),
+ this.getBkDir(), this.isWipeData(), "127.0.0.1");
bkEnsemble.startStandalone(!this.isNoStreamStorage());
}
@@ -352,7 +353,7 @@ public class PulsarStandalone implements AutoCloseable {
log.info(e.getMessage());
}
}
-
+
/** this methods gets a buidler to use to build and an embedded pulsar
instance `
* i.e.
* <pre>