@Test void multipleTopicsCommaDelimited() {
    try (KafkaCollector collector = builder("topic1,topic2").build()) {
      collector.start();

      assertThat(collector.kafkaWorkers.workers.get(0).topics).containsExactly("topic1", "topic2");
    }
  }
Guards against errors that leak from storage, such as InvalidQueryException
zipkin-collector/kafka/src/test/java/zipkin2/collector/kafka/ITKafkaCollector.java