test(encode_decode_test): add test case for malformed JSON

Author: julia-godoy

src/kafka/encode_decode_test.go

@@ -35,3 +35,17 @@ func TestDecoder_JsonMessageToRecord(t *testing.T) {
 	assert.Nil(t, err)
 	assert.Equal(t, val, returnedVal)
 }
+
+func TestDecoder_JsonMessageToRecord_MalformedJson(t *testing.T) {
+	d := &Decoder{CodecCache: sync.Map{}}
+	jsonBytes := []byte(`{"alo": 60"`)
+	record, err := d.JsonMessageToRecord(context.Background(), &sarama.ConsumerMessage{
+		Value:     jsonBytes,
+		Topic:     "test",
+		Partition: 1,
+		Offset:    54,
+		Timestamp: time.Now(),
+	})
+	assert.Nil(t, record)
+	assert.NotNil(t, err)
+}