From 2a9397c35d32d46c1bc5e68aaf45c04917527748 Mon Sep 17 00:00:00 2001
From: linonymous <linonymous@gmail.com>
Date: Tue, 7 Dec 2021 19:51:25 +0530
Subject: [PATCH] Fix firehose response creation

Signed-off-by: linonymous <linonymous@gmail.com>
---
 firehose/firehose.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/firehose/firehose.go b/firehose/firehose.go
index 8fa149d..1c95893 100644
--- a/firehose/firehose.go
+++ b/firehose/firehose.go
@@ -263,7 +263,11 @@ func (c *ClientProvider) send(channel string, records []interface{}) ([]*PutResp
 	var res []*PutResponse
 	for _, r := range recordBatch.RequestResponses {
 		if r.RecordId != nil {
-			res = append(res, &PutResponse{RecordID: *r.RecordId, Error: errors.New(*r.ErrorMessage)})
+			response := &PutResponse{RecordID: *r.RecordId}
+			if r.ErrorMessage != nil {
+				response.Error = errors.New(*r.ErrorMessage)
+			}
+			res = append(res, response)
 		}
 	}
 	return res, nil