Added body in the error topic header (#1830)

Signed-off-by: therahulbhati <rjbhati009@gmail.com>

Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com>
Co-authored-by: Sanket Sudake <sanketsudake@gmail.com>
This commit is contained in:
Rahul Bhati
2021-06-07 22:28:11 +05:30
committed by GitHub
co-authored by Vishal Sanket Sudake
parent 5b1883802e
commit 3055a3ada0
+1 -1
View File
@@ -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)