Skip to content

Commit 51312af

Browse files
authored
fix(kafka): Disable defaults address defaults (#17825)
1 parent 5b5838e commit 51312af

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/kafka/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) {
8686
cfg.ReaderConfig.RegisterFlagsWithPrefix(prefix+".reader", f)
8787
cfg.WriterConfig.RegisterFlagsWithPrefix(prefix+".writer", f)
8888

89-
f.StringVar(&cfg.Address, prefix+".address", "localhost:9092", "The Kafka backend address. This setting is deprecated and will be removed in the next minor release.")
89+
f.StringVar(&cfg.Address, prefix+".address", "", "The Kafka backend address. This setting is deprecated and will be removed in the next minor release.")
9090
f.StringVar(&cfg.Topic, prefix+".topic", "", "The Kafka topic name.")
9191
f.StringVar(&cfg.ClientID, prefix+".client-id", "", "The Kafka client ID. This setting is deprecated and will be removed in the next minor release.")
9292
f.DurationVar(&cfg.DialTimeout, prefix+".dial-timeout", 2*time.Second, "The maximum time allowed to open a connection to a Kafka broker.")

0 commit comments

Comments
 (0)