From 88b534377540995cbaaac0175ad0845378456957 Mon Sep 17 00:00:00 2001
From: cocoifly10 <619942796@qq.com>
Date: Wed, 14 Aug 2019 17:07:29 +0800
Subject: [PATCH] Fix Kafka message queue trigger panic problem caused by
 err.Error() (#1271)

fix bug: panic: runtime error: invalid memory address or nil pointer dereference
---
 pkg/mqtrigger/messageQueue/kafka.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pkg/mqtrigger/messageQueue/kafka.go b/pkg/mqtrigger/messageQueue/kafka.go
index 37609525..f60bb161 100644
--- a/pkg/mqtrigger/messageQueue/kafka.go
+++ b/pkg/mqtrigger/messageQueue/kafka.go
@@ -17,6 +17,7 @@ limitations under the License.
 package messageQueue
 
 import (
+	"fmt"
 	"io/ioutil"
 	"net/http"
 	"os"
@@ -214,7 +215,7 @@ func kafkaMsgHandler(kafka *Kafka, producer sarama.SyncProducer, trigger *fv1.Me
 	}
 	if resp.StatusCode != 200 {
 		errorHandler(kafka.logger, trigger, producer, url,
-			errors.Wrapf(err, "request returned failure: %v", resp.StatusCode))
+			fmt.Errorf("request returned failure: %v", resp.StatusCode))
 		return false
 	}
 	if len(trigger.Spec.ResponseTopic) > 0 {