edit unittests for JSON parser

2018-06-27 16:09:14 -07:00
parent 420dafd591
commit c50bfc2c71
9 changed files with 14 additions and 14 deletions
@@ -125,7 +125,7 @@ func TestRunParserAndGatherJSON(t *testing.T) {
 	k.acc = &acc
 	defer close(k.done)

-	k.parser, _ = parsers.NewJSONParser("kafka_json_test", []string{}, nil)
+	k.parser, _ = parsers.NewJSONParser("kafka_json_test", []string{}, nil, nil)
 	go k.receiver()
 	in <- saramaMsg(testMsgJSON)
 	acc.Wait(1)