class SnowdropKafkaProducer implements KafkaProducer<K, V> {

    @Override
    public Mono<Void> write(ProducerRecord<K, V> record) {
        Objects.requireNonNull(record, "Record cannot be null");

        return delegate.write(toMutinyProducerRecord(record)).convert().with(UniReactorConverters.toMono());
    }

      SnowdropKafkaProducer(io.vertx.mutiny.kafka.client.producer.KafkaProducer<K, V> delegate);

}