class SnowdropKafkaConsumer implements KafkaConsumer<K, V> {

    @Override
    public Flux<ConsumerRecord<K, V>> flux() {
        return delegate.toMulti()
            .convert()
            .with(MultiReactorConverters.toFlux())
            .map(SnowdropConsumerRecord::new);
    }

      SnowdropKafkaConsumer(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K, V> delegate);

}