From 1820507da0686b1c82bffaf8f54d8be2508a648e Mon Sep 17 00:00:00 2001 From: Krisztian Gacsal Date: Mon, 21 Oct 2024 10:38:45 +0200 Subject: [PATCH] refactor: Kafka config defaults --- app/config/kafka.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/config/kafka.go b/app/config/kafka.go index 6558f157c..66838ede6 100644 --- a/app/config/kafka.go +++ b/app/config/kafka.go @@ -58,14 +58,14 @@ func ConfigureKafkaConfiguration(v *viper.Viper, prefix string) { v.SetDefault(AddPrefix(prefix, "kafka.saslUsername"), "") v.SetDefault(AddPrefix(prefix, "kafka.saslPassword"), "") v.SetDefault(AddPrefix(prefix, "kafka.statsInterval"), 0) - v.SetDefault(AddPrefix(prefix, "kafka.brokerAddressFamily"), "any") + v.SetDefault(AddPrefix(prefix, "kafka.brokerAddressFamily"), nil) v.SetDefault(AddPrefix(prefix, "kafka.topicMetadataRefreshInterval"), 0) v.SetDefault(AddPrefix(prefix, "kafka.socketKeepAliveEnabled"), false) v.SetDefault(AddPrefix(prefix, "kafka.debugContexts"), nil) v.SetDefault(AddPrefix(prefix, "kafka.clientID"), "") v.SetDefault(AddPrefix(prefix, "kafka.consumerGroupID"), "") v.SetDefault(AddPrefix(prefix, "kafka.consumerGroupInstanceID"), "") - v.SetDefault(AddPrefix(prefix, "kafka.sessionTimeout"), 0) + v.SetDefault(AddPrefix(prefix, "kafka.sessionTimeout"), "9s") v.SetDefault(AddPrefix(prefix, "kafka.heartbeatInterval"), 0) v.SetDefault(AddPrefix(prefix, "kafka.enableAutoCommit"), true) v.SetDefault(AddPrefix(prefix, "kafka.enableAutoOffsetStore"), true)