Fix failing kafka integration test (#1068)

Signed-off-by: Pavol Loffay <[email protected]>
jaegertracing · Sep 20, 2018 · 79d10f2 · 79d10f2
1 parent f4438f7
commit 79d10f2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/plugin/storage/integration/kafka_test.go b/plugin/storage/integration/kafka_test.go
@@ -88,7 +88,11 @@ func (s *KafkaIntegrationTestSuite) initialize() error {
 	s.SpanWriter = spanWriter
 	s.SpanReader = &ingester{traceStore}
 	s.Refresh = func() error { return nil }
-	s.CleanUp = func() error { return nil }
+	s.CleanUp = func() error {
+		// TODO close would not work if multiple tests are run
+		spanConsumer.Close()
+		return nil
+	}
 	return nil
 }