Skip to content
This repository has been archived by the owner on Apr 11, 2024. It is now read-only.

Commit

Permalink
feat: default dynamic listener ip set to 0.0.0.0 (#40)
Browse files Browse the repository at this point in the history
  • Loading branch information
smoya committed Sep 13, 2021
1 parent 8464393 commit 6660c31
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions kafka/proxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
Expand Down

0 comments on commit 6660c31

Please sign in to comment.