suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartition: TopicPartition): Unit suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartitions: Set<TopicPartition>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.assign |
|
suspend fun <K, V> KafkaConsumer<K, V>.assignmentAwait(): Set<TopicPartition>
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.assignment |
|
suspend fun <K, V> KafkaConsumer<K, V>.beginningOffsetsAwait(topicPartition: TopicPartition): Long
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets |
|
suspend fun <K, V> KafkaConsumer<K, V>.closeAwait(): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.close |
|
suspend fun <K, V> KafkaConsumer<K, V>.commitAwait(): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.commit |
|
suspend fun <K, V> KafkaConsumer<K, V>.committedAwait(topicPartition: TopicPartition): OffsetAndMetadata
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.committed |
|
suspend fun <K, V> KafkaConsumer<K, V>.endOffsetsAwait(topicPartition: TopicPartition): Long
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets |
|
suspend fun <K, V> KafkaConsumer<K, V>.offsetsForTimesAwait(topicPartition: TopicPartition, timestamp: Long): OffsetAndTimestamp
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes |
|
suspend fun <K, V> KafkaConsumer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.partitionsFor |
|
suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartition: TopicPartition): Unit suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartitions: Set<TopicPartition>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.pause |
|
suspend fun <K, V> KafkaConsumer<K, V>.pausedAwait(): Set<TopicPartition>
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.paused |
|
suspend fun <K, V> KafkaConsumer<K, V>.pipeToAwait(dst: WriteStream<KafkaConsumerRecord<K, V>>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.pipeTo |
|
suspend fun <K, V> KafkaConsumer<K, V>.pollAwait(timeout: Long): KafkaConsumerRecords<K, V>
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.poll |
|
suspend fun <K, V> KafkaConsumer<K, V>.positionAwait(partition: TopicPartition): Long
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.position |
|
suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartition: TopicPartition): Unit suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartitions: Set<TopicPartition>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.resume |
|
suspend fun <K, V> KafkaConsumer<K, V>.seekAwait(topicPartition: TopicPartition, offset: Long): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.seek |
|
suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartition: TopicPartition): Unit suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartitions: Set<TopicPartition>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.seekToBeginning |
|
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartition: TopicPartition): Unit suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartitions: Set<TopicPartition>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.seekToEnd |
|
suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topic: String): Unit suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topics: Set<String>): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.subscribe |
|
suspend fun <K, V> KafkaConsumer<K, V>.subscriptionAwait(): Set<String>
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.subscription |
|
suspend fun <K, V> KafkaConsumer<K, V>.unsubscribeAwait(): Unit
Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe |