From 3055a3ada00b286c5ad2ba366b9c333dad333fe4 Mon Sep 17 00:00:00 2001 From: Rahul Bhati Date: Mon, 7 Jun 2021 22:28:11 +0530 Subject: [PATCH] Added body in the error topic header (#1830) Signed-off-by: therahulbhati Co-authored-by: Vishal Co-authored-by: Sanket Sudake --- pkg/mqtrigger/messageQueue/kafka/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/mqtrigger/messageQueue/kafka/kafka.go b/pkg/mqtrigger/messageQueue/kafka/kafka.go index e409acd9..38332fe6 100644 --- a/pkg/mqtrigger/messageQueue/kafka/kafka.go +++ b/pkg/mqtrigger/messageQueue/kafka/kafka.go @@ -322,7 +322,7 @@ func kafkaMsgHandler(kafka *Kafka, producer sarama.SyncProducer, trigger *fv1.Me return } if resp.StatusCode != 200 { - errorString := string("request returned failure: " + strconv.Itoa(resp.StatusCode)) + errorString := fmt.Sprintf("request returned failure: %v, request body error: %v", resp.StatusCode, body) errorHeaders := generateErrorHeaders(errorString) errorHandler(kafka.logger, trigger, producer, url, fmt.Errorf("request returned failure: %v", resp.StatusCode), errorHeaders)