class SnowdropKafkaProducer implements KafkaProducer<K, V> {

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

        return delegate.send(toMutinyProducerRecord(record))
            .convert()
            .with(UniReactorConverters.toMono())
            .map(SnowdropRecordMetadata::new);
    }

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

}