diff --git a/processor_test.go b/processor_test.go index 86da01a4..3db467d4 100644 --- a/processor_test.go +++ b/processor_test.go @@ -351,7 +351,6 @@ func TestProcessor_Run(t *testing.T) { consBuilder, _ := createTestConsumerBuilder(t) graph := DefineGroup("test", - // not really used, we're failing anyway Input("input", new(codec.Int64), accumulate), )