feat: mk broker.address.family configurable

openmeterio · May 14, 2024 · e8e8bc7 · e8e8bc7
1 parent 0883f29
commit e8e8bc7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/config/ingest.go b/config/ingest.go
@@ -30,6 +30,7 @@ type KafkaIngestConfiguration struct {
 	SaslPassword        string
 	Partitions          int
 	EventsTopicTemplate string
+	BrokerAddressFamily string
 }
 
 // CreateKafkaConfig creates a Kafka config map.
@@ -44,7 +45,9 @@ func (c KafkaIngestConfiguration) CreateKafkaConfig() kafka.ConfigMap {
 	// This is needed when using localhost brokers on OSX,
 	// since the OSX resolver will return the IPv6 addresses first.
 	// See: https://github.com/openmeterio/openmeter/issues/321
-	if strings.Contains(c.Broker, "localhost") || strings.Contains(c.Broker, "127.0.0.1") {
+	if c.BrokerAddressFamily != "" {
+		config["broker.address.family"] = c.BrokerAddressFamily
+	} else if strings.Contains(c.Broker, "localhost") || strings.Contains(c.Broker, "127.0.0.1") {
 		config["broker.address.family"] = "v4"
 	}