@Override
          public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
            assignedPartitions.set(List.copyOf(partitions));
          }
Consumes spans from Kafka messages, ignoring malformed input
zipkin-collector/kafka/src/main/java/zipkin2/collector/kafka/KafkaCollectorWorker.java