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	Description
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, 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
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
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.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.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.pollTimeout(java.time.Duration timeout)	Sets the poll timeout for the underlying native Kafka Consumer.
KafkaReadStream<K,V>	KafkaReadStream.resume()