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

Packages that use KafkaConsumer

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

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

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

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

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

Modifier and Type	Method and 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, 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 .
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
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(java.time.Duration timeout) Sets the poll timeout for the underlying native Kafka Consumer.
KafkaConsumer<K,V>	KafkaConsumer.resume()