KafkaCollector.Builder builder(String topic, int streams) {
    return kafka.newCollectorBuilder(topic, streams)
      .metrics(metrics)
      .storage(buildStorage(consumer));
  }
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