class SnowdropKafkaConsumer implements KafkaConsumer<K, V> {

    @Override
    public Mono<Long> timeOffset(Partition partition, long timestamp) {
        Objects.requireNonNull(partition, "Partition cannot be null");
        if (timestamp < 0) {
            throw new IllegalArgumentException("Timestamp cannot be negative");
        }

        return delegate.offsetsForTimes(toVertxTopicPartition(partition), timestamp)
            .convert()
            .with(UniReactorConverters.toMono())
            .map(OffsetAndTimestamp::getOffset);
    }

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

}