Merge pull request #1728 from openmeterio/refactor/kafka-config-defaults

refactor: Kafka config defaults
openmeterio · Oct 21, 2024 · 6a50601 · 6a50601
2 parents 918992f + 1820507
commit 6a50601
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)