vertx / io.vertx.reactivex.kafka.client.consumer / KafkaConsumer / rxSubscription

rxSubscription

open fun rxSubscription(): Single<MutableSet<String>>

Get the current subscription.

Return