From 9c63975497d83c09809e1050dd140bd7e9008417 Mon Sep 17 00:00:00 2001
From: Suraj Banakar <34534103+vadasambar@users.noreply.github.com>
Date: Tue, 20 Aug 2019 17:15:56 +0530
Subject: [PATCH] Fix typo "consumer" => "producer" (#1278)

---
 pkg/mqtrigger/messageQueue/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/mqtrigger/messageQueue/kafka.go b/pkg/mqtrigger/messageQueue/kafka.go
index f60bb161..c7d62dd5 100644
--- a/pkg/mqtrigger/messageQueue/kafka.go
+++ b/pkg/mqtrigger/messageQueue/kafka.go
@@ -93,7 +93,7 @@ func (kafka Kafka) subscribe(trigger *fv1.MessageQueueTrigger) (messageQueueSubs
 	producerConfig.Producer.Return.Successes = true
 	producerConfig.Version = kafka.version
 	producer, err := sarama.NewSyncProducer(kafka.brokers, producerConfig)
-	kafka.logger.Info("created a new producer", zap.Any("consumer", producer))
+	kafka.logger.Info("created a new producer", zap.Any("producer", producer))
 	if err != nil {
 		panic(err)
 	}