fix: use kafka configuration to create admin client

Signed-off-by: Mark Sagi-Kazar <[email protected]>
openmeterio · Oct 11, 2024 · 4c70110 · 4c70110
1 parent 813cf00
commit 4c70110
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.