iconsume and consumer tests

port-labs · Dec 18, 2023 · 3e3c91c · 3e3c91c
1 parent a1e4031
commit 3e3c91c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/pkg/event_listener/consumer/consumer.go b/pkg/event_listener/consumer/consumer.go
@@ -23,10 +23,10 @@ type Consumer struct {
 
 type JsonHandler func(value []byte)
 
-func NewConsumer(config *config.KafkaConfiguration, overrideConsumer IConsume) (*Consumer, error) {
-	c := overrideConsumer
+func NewConsumer(config *config.KafkaConfiguration, overrideKafkaConsumer IConsume) (*Consumer, error) {
+	c := overrideKafkaConsumer
 	var err error
-	if overrideConsumer == nil {
+	if overrideKafkaConsumer == nil {
 		c, err = kafka.NewConsumer(&kafka.ConfigMap{
 			"bootstrap.servers": config.Brokers,
 			"client.id":         "port-k8s-exporter",

diff --git a/pkg/event_listener/event_listener_handler.go b/pkg/event_listener/event_listener_handler.go
@@ -72,7 +72,7 @@ func startKafkaEventListener(l *EventListener, resync func()) error {
 	}
 
 	topic := orgId + ".change.log"
-	instance, err := consumer.NewConsumer(c)
+	instance, err := consumer.NewConsumer(c, nil)
 
 	if err != nil {
 		return err