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) Manually assign a set of partitions to this consumer.
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, 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) Suspend fetching from the requested partitions.
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.pollTimeout(long timeout) Deprecated. use pollTimeout(Duration)
KafkaReadStream<K,V>	KafkaReadStream.resume()
KafkaReadStream<K,V>	KafkaReadStream.resume(Set<org.apache.kafka.common.TopicPartition> topicPartitions) Resume specified partitions which have been paused with pause.
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) Overrides the fetch offsets that the consumer will use on the next poll.
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) Seek to the first offset for each of the given partitions.
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) Seek to the last 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) Subscribe to all topics matching specified pattern to get dynamically assigned 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) Subscribe to the given list of topics 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() Unsubscribe from topics currently subscribed with subscribe.
KafkaReadStream<K,V>	KafkaReadStream.unsubscribe(Handler<AsyncResult<Void>> completionHandler) Unsubscribe from topics currently subscribed with subscribe.