## Uses of Interface
io.vertx.kafka.client.consumer.KafkaReadStream

- Packages that use KafkaReadStream
  Package | Description
  --- | ---
  io.vertx.kafka.client.consumer |

- - ### Uses of KafkaReadStream in io.vertx.kafka.client.consumer

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

Copyright © 2025 Eclipse. All rights reserved.