void produceSpans(byte[] spans, String topic) {
    produceSpans(spans, topic, 0);
  }
Wait until all kafka consumers created by the collector have at least one partition assigned.
zipkin-collector/kafka/src/test/java/zipkin2/collector/kafka/ITKafkaCollector.java