Merge pull request #1657 from openmeterio/wire-kafka-fix

fix: use kafka configuration to create admin client
openmeterio · Oct 11, 2024 · 9d2ee06 · 9d2ee06
2 parents 813cf00 + 4c70110
commit 9d2ee06
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 5 deletions.
diff --git a/cmd/balance-worker/wire_gen.go b/cmd/balance-worker/wire_gen.go
diff --git a/cmd/notification-service/wire_gen.go b/cmd/notification-service/wire_gen.go
diff --git a/cmd/server/wire_gen.go b/cmd/server/wire_gen.go
diff --git a/cmd/sink-worker/wire_gen.go b/cmd/sink-worker/wire_gen.go
diff --git a/openmeter/app/kafka.go b/openmeter/app/kafka.go
@@ -43,7 +43,7 @@ func NewKafkaMetrics(meter metric.Meter) (*kafkametrics.Metrics, error) {
 	return metrics, nil
 }
 
-func NewKafkaAdminClient(conf config.KafkaIngestConfiguration) (*kafka.AdminClient, error) {
+func NewKafkaAdminClient(conf config.KafkaConfiguration) (*kafka.AdminClient, error) {
 	kafkaConfigMap := conf.CreateKafkaConfig()
 	// NOTE(chrisgacsal): remove 'go.logs.channel.enable' configuration parameter as it is not supported by AdminClient
 	// and initializing the client fails if this parameter is set.