void produceSpans(byte[] spans, String topic, Integer partition) {
    producer.send(new ProducerRecord<>(topic, partition, null, spans));
    producer.flush();
  }
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