Uses of Interface
io.vertx.kafka.client.consumer.KafkaConsumer

Packages that use KafkaConsumer

Package	Description
io.vertx.kafka.client.consumer
io.vertx.reactivex.kafka.client.consumer
io.vertx.rxjava.kafka.client.consumer
io.vertx.rxjava3.kafka.client.consumer

Uses of KafkaConsumer in io.vertx.kafka.client.consumer

Methods in io.vertx.kafka.client.consumer that return KafkaConsumer

Modifier and Type	Method and Description
KafkaConsumer<K,V>	KafkaConsumer.assign(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler) Manually assign a list of partition to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.assign(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler) Manually assign a partition to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.assignment(Handler<AsyncResult<Set<TopicPartition>>> handler) Get the set of partitions currently assigned to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.batchHandler(Handler<KafkaConsumerRecords<K,V>> handler) Set the handler to be used when batches of messages are fetched from the Kafka server.
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,V> consumer) Create a new KafkaConsumer instance from a native Consumer.
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, KafkaClientOptions options) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, KafkaClientOptions options, Class<K> keyType, Class<V> valueType) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, KafkaClientOptions options, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Map<String,String> config) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Map<String,String> config, Class<K> keyType, Class<V> valueType) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Map<String,String> config, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Properties config) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType) Create a new KafkaConsumer instance
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) Create a new KafkaConsumer instance
KafkaConsumer<K,V>	KafkaConsumer.endHandler(Handler<Void> endHandler)
KafkaConsumer<K,V>	KafkaConsumer.exceptionHandler(Handler<Throwable> handler)
KafkaConsumer<K,V>	KafkaConsumer.fetch(long amount)
KafkaConsumer<K,V>	KafkaConsumer.handler(Handler<KafkaConsumerRecord<K,V>> handler)
KafkaConsumer<K,V>	KafkaConsumer.listTopics(Handler<AsyncResult<Map<String,List<PartitionInfo>>>> handler) Get metadata about partitions for all topics that the user is authorized to view.
KafkaConsumer<K,V>	KafkaConsumer.partitionsAssignedHandler(Handler<Set<TopicPartition>> handler) Set the handler called when topic partitions are assigned to the consumer
KafkaConsumer<K,V>	KafkaConsumer.partitionsFor(String topic, Handler<AsyncResult<List<PartitionInfo>>> handler) Get metadata about the partitions for a given topic.
KafkaConsumer<K,V>	KafkaConsumer.partitionsRevokedHandler(Handler<Set<TopicPartition>> handler) Set the handler called when topic partitions are revoked to the consumer
KafkaConsumer<K,V>	KafkaConsumer.pause()
KafkaConsumer<K,V>	KafkaConsumer.pause(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler) Suspend fetching from the requested partitions.
KafkaConsumer<K,V>	KafkaConsumer.pause(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler) Suspend fetching from the requested partition.
KafkaConsumer<K,V>	KafkaConsumer.pollTimeout(java.time.Duration timeout) Sets the poll timeout for the underlying native Kafka Consumer.
KafkaConsumer<K,V>	KafkaConsumer.resume()
KafkaConsumer<K,V>	KafkaConsumer.resume(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler) Resume specified partitions which have been paused with pause.
KafkaConsumer<K,V>	KafkaConsumer.resume(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler) Resume specified partition which have been paused with pause.
KafkaConsumer<K,V>	KafkaConsumer.seek(TopicPartition topicPartition, long offset, Handler<AsyncResult<Void>> completionHandler) Overrides the fetch offsets that the consumer will use on the next poll.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginning(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler) Seek to the first offset for each of the given partitions.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginning(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler) Seek to the first offset for each of the given partition.
KafkaConsumer<K,V>	KafkaConsumer.seekToEnd(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler) Seek to the last offset for each of the given partitions.
KafkaConsumer<K,V>	KafkaConsumer.seekToEnd(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler) Seek to the last offset for each of the given partition.
KafkaConsumer<K,V>	KafkaConsumer.subscribe(Pattern pattern, Handler<AsyncResult<Void>> completionHandler) Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscribe(Set<String> topics, Handler<AsyncResult<Void>> completionHandler) Subscribe to the given list of topics to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscribe(String topic, Handler<AsyncResult<Void>> completionHandler) Subscribe to the given topic to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscription(Handler<AsyncResult<Set<String>>> handler) Get the current subscription.
KafkaConsumer<K,V>	KafkaConsumer.unsubscribe(Handler<AsyncResult<Void>> completionHandler) Unsubscribe from topics currently subscribed with subscribe.

Uses of KafkaConsumer in io.vertx.reactivex.kafka.client.consumer

Methods in io.vertx.reactivex.kafka.client.consumer that return KafkaConsumer

Modifier and Type	Method and Description
KafkaConsumer	KafkaConsumer.getDelegate()

Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumer

Modifier and Type	Method and Description
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg)
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumer

Constructor and Description
KafkaConsumer(KafkaConsumer delegate)

Uses of KafkaConsumer in io.vertx.rxjava.kafka.client.consumer

Methods in io.vertx.rxjava.kafka.client.consumer that return KafkaConsumer

Modifier and Type	Method and Description
KafkaConsumer	KafkaConsumer.getDelegate()

Methods in io.vertx.rxjava.kafka.client.consumer with parameters of type KafkaConsumer

Modifier and Type	Method and Description
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg)
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.rxjava.kafka.client.consumer with parameters of type KafkaConsumer

Constructor and Description
KafkaConsumer(KafkaConsumer delegate)

Uses of KafkaConsumer in io.vertx.rxjava3.kafka.client.consumer

Methods in io.vertx.rxjava3.kafka.client.consumer that return KafkaConsumer

Modifier and Type	Method and Description
KafkaConsumer	KafkaConsumer.getDelegate()

Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumer

Modifier and Type	Method and Description
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg)
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(KafkaConsumer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumer

Constructor and Description
KafkaConsumer(KafkaConsumer delegate)