[Fix] Incorrect kafka example event and marshaling (#392)

* fix incorrect kafka test json * fix incorrect kafka test json 2/2 Co-authored-by: Peiyu Wu <[email protected]>
aws · Sep 17, 2021 · 2442858 · 2442858
1 parent 85e7bc7
commit 2442858
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 13 deletions.
diff --git a/events/kafka_test.go b/events/kafka_test.go
@@ -39,6 +39,15 @@ func TestKafkaEventMarshaling(t *testing.T) {
 			}
 		}
 	}
+
+	// 3. serialize to JSON
+	outputJson, err := json.Marshal(inputEvent)
+	if err != nil {
+		t.Errorf("could not marshal event. details: %v", err)
+	}
+
+	// 4. check result
+	assert.JSONEq(t, string(inputJson), string(outputJson))
 }
 
 func TestKafkaMarshalingMalformedJson(t *testing.T) {

diff --git a/events/testdata/kafka-event.json b/events/testdata/kafka-event.json
@@ -14,19 +14,7 @@
           "value": "OGQ1NTk2YjQtMTgxMy00MjM4LWIyNGItNmRhZDhlM2QxYzBj",
           "headers": [
             {
-              "headerKey": [
-                104,
-                101,
-                97,
-                100,
-                101,
-                114,
-                86,
-                97,
-                108,
-                117,
-                101
-              ]
+              "headerKey": "aGVhZGVyVmFsdWU="
             }
           ]
         }