diff --git a/broker/broker.py b/broker/broker.py index ae569af..b5b440a 100644 --- a/broker/broker.py +++ b/broker/broker.py @@ -105,7 +105,7 @@ def DropReplicaMessages(self, request, context): server = grpc.server(ThreadPoolExecutor(max_workers=10)) broker = BrokerServer() broker_pb2_grpc.add_BrokerServicer_to_server(broker, server) - server.add_insecure_port(f'[::]:{os.environ["BROKER_PORT"]}') + server.add_insecure_port(f'0.0.0.0:{os.environ["BROKER_PORT"]}') server.start() channel = grpc.insecure_channel(f'{os.environ["ZOOKEEPER_HOST"]}:{os.environ["ZOOKEEPER_PORT"]}') stub = proto.zookeeper_pb2_grpc.ZookeeperStub(channel) diff --git a/zookeeper/zookeeper.py b/zookeeper/zookeeper.py index 9e78453..1d37659 100644 --- a/zookeeper/zookeeper.py +++ b/zookeeper/zookeeper.py @@ -67,6 +67,6 @@ def Register(self, request, context): manager = BrokerManager() message_pb2_grpc.add_MessageQueueServicer_to_server(MessageQueue(manager), server) zookeeper_pb2_grpc.add_ZookeeperServicer_to_server(Zookeeper(manager), server) - server.add_insecure_port(f"[::]:{os.getenv('ZOOKEEPER_PORT')}") + server.add_insecure_port(f"0.0.0.0:{os.getenv('ZOOKEEPER_PORT')}") server.start() server.wait_for_termination()