Uses of Interface
io.vertx.kafka.client.consumer.KafkaConsumerRecords
-
Packages that use KafkaConsumerRecords Package Description io.vertx.kafka.client.consumer io.vertx.reactivex.kafka.client.consumer io.vertx.rxjava3.kafka.client.consumer -
-
Uses of KafkaConsumerRecords in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer that return types with arguments of type KafkaConsumerRecords Modifier and Type Method Description Future<KafkaConsumerRecords<K,V>>KafkaConsumer. poll(java.time.Duration timeout)Executes a poll for getting messages from Kafka.Method parameters in io.vertx.kafka.client.consumer with type arguments of type KafkaConsumerRecords Modifier and Type Method 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. -
Uses of KafkaConsumerRecords in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer that return KafkaConsumerRecords Modifier and Type Method Description KafkaConsumerRecordsKafkaConsumerRecords. getDelegate()Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumerRecords Modifier and Type Method Description static <K,V>
KafkaConsumerRecords<K,V>KafkaConsumerRecords. newInstance(KafkaConsumerRecords arg)static <K,V>
KafkaConsumerRecords<K,V>KafkaConsumerRecords. newInstance(KafkaConsumerRecords arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)Constructors in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumerRecords Constructor Description KafkaConsumerRecords(KafkaConsumerRecords delegate) -
Uses of KafkaConsumerRecords in io.vertx.rxjava3.kafka.client.consumer
Methods in io.vertx.rxjava3.kafka.client.consumer that return KafkaConsumerRecords Modifier and Type Method Description KafkaConsumerRecordsKafkaConsumerRecords. getDelegate()Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumerRecords Modifier and Type Method Description static <K,V>
KafkaConsumerRecords<K,V>KafkaConsumerRecords. newInstance(KafkaConsumerRecords arg)static <K,V>
KafkaConsumerRecords<K,V>KafkaConsumerRecords. newInstance(KafkaConsumerRecords arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)Constructors in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumerRecords Constructor Description KafkaConsumerRecords(KafkaConsumerRecords delegate)
-