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)