Merge pull request #903 from openmeterio/conf-broker-addr-family

feat: mk broker.address.family configurable
openmeterio · May 14, 2024 · 0ac71c6 · 0ac71c6
2 parents 0883f29 + e8e8bc7
commit 0ac71c6
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"
 	}