Fix typo "consumer" => "producer" (#1278)

2019-08-20 19:45:56 +08:00
parent 8cafe1ebf3
commit 9c63975497
1 changed files with 1 additions and 1 deletions
@@ -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)
 	}