@Override
          public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
            // technically we should remove only the revoked partitions but for test purposes it
            // does not matter
            assignedPartitions.set(List.of());
          }
Consumes spans from Kafka messages, ignoring malformed input
zipkin-collector/kafka/src/main/java/zipkin2/collector/kafka/KafkaCollectorWorker.java