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 and Description
static io.vertx.lang.rx.TypeArg<KafkaConsumer>	KafkaConsumer.__TYPE_ARG

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

Modifier and Type	Method and Description
KafkaConsumer<K,V>	KafkaConsumer.assign(Set<TopicPartition> topicPartitions) Manually assign a list of partition to this consumer.
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) Manually assign a 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() Get the set of partitions currently assigned 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, 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.partitionsFor(String topic) Get metadata about the partitions for a given topic.
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) Suspend fetching from the requested partitions.
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) Suspend fetching from the requested partition.
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) Resume specified partitions which have been paused with pause.
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) Resume specified partition 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) Overrides the fetch offsets that the consumer will use on the next poll.
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) Seek to the first offset for each of the given partitions.
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) Seek to the first offset for each of the given partition.
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) Seek to the last offset for each of the given partitions.
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) Seek to the last offset for each of the given partition.
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(Set<String> topics) Subscribe to the given list of topics 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) Subscribe to the given topic 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() Get the current subscription.
KafkaConsumer<K,V>	KafkaConsumer.subscription(Handler<AsyncResult<Set<String>>> handler) Get the current subscription.
KafkaConsumer<K,V>	KafkaConsumer.unsubscribe() Unsubscribe from topics currently subscribed with subscribe.
KafkaConsumer<K,V>	KafkaConsumer.unsubscribe(Handler<AsyncResult<Void>> completionHandler) Unsubscribe from topics currently subscribed with subscribe.