From 6660c310429eb17ce7692a277ab88f870c1c9fc5 Mon Sep 17 00:00:00 2001 From: Sergio Moya <1083296+smoya@users.noreply.github.com> Date: Mon, 13 Sep 2021 13:39:05 +0200 Subject: [PATCH] feat: default dynamic listener ip set to 0.0.0.0 (#40) --- kafka/proxy.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kafka/proxy.go b/kafka/proxy.go index f1bdd68..b290e90 100644 --- a/kafka/proxy.go +++ b/kafka/proxy.go @@ -46,6 +46,9 @@ func NewProxy(c *ProxyConfig) (proxy.Proxy, error) { // Yeah, not a good practice at all but I guess it's fine for now. kafkaproxy.ActualDefaultRequestHandler.RequestKeyHandlers.Set(protocol.RequestAPIKeyProduce, NewProduceRequestHandler(c.MessageHandlers...)) + // Setting some defaults. + _ = server.Server.Flags().Set("default-listener-ip", "0.0.0.0") // Binding to all local network interfaces. Needed for external calls. + if c.BrokersMapping == nil { return nil, errors.New("Brokers mapping is required") }