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

Packages that use KafkaConsumer

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

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

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

Modifier and Type	Field	Description
static final io.vertx.lang.rx.TypeArg<KafkaConsumer>	KafkaConsumer.__TYPE_ARG

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

Modifier and Type	Method	Description
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, 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, 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, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)	Create a new KafkaConsumer instance from a native .
static <K,V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, KafkaClientOptions options)	Create a new KafkaConsumer instance from a native .
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)
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)
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.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.pollTimeout(Duration timeout)	Sets the poll timeout for the underlying native Kafka Consumer.
KafkaConsumer<K,V>	KafkaConsumer.resume()