Merge pull request #10 from LF-Engineering/fix-firehose-put

Fix firehose response creation
LF-Engineering · Dec 7, 2021 · 100832f · 100832f
2 parents 9c9762e + 2a9397c
commit 100832f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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