class SnowdropKafkaConsumer implements KafkaConsumer<K, V> {

    @Override
    public ReadStream vertxReadStream() {
        return delegate.getDelegate();
    }

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

}