vertx / io.vertx.kotlin.kafka.client.consumer / io.vertx.kafka.client.consumer.KafkaConsumer

### Extensions for io.vertx.kafka.client.consumer.KafkaConsumer

assignAwait | `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
assignmentAwait | `suspend fun <K, V> KafkaConsumer<K, V>.assignmentAwait(): Set<TopicPartition>` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.assignment
beginningOffsetsAwait | `suspend fun <K, V> KafkaConsumer<K, V>.beginningOffsetsAwait(topicPartition: TopicPartition): Long` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets
closeAwait | `suspend fun <K, V> KafkaConsumer<K, V>.closeAwait(): Unit` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.close
commitAwait | `suspend fun <K, V> KafkaConsumer<K, V>.commitAwait(): Unit` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.commit
committedAwait | `suspend fun <K, V> KafkaConsumer<K, V>.committedAwait(topicPartition: TopicPartition): OffsetAndMetadata` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.committed
endOffsetsAwait | `suspend fun <K, V> KafkaConsumer<K, V>.endOffsetsAwait(topicPartition: TopicPartition): Long` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets
offsetsForTimesAwait | `suspend fun <K, V> KafkaConsumer<K, V>.offsetsForTimesAwait(topicPartition: TopicPartition, timestamp: Long): OffsetAndTimestamp` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes
partitionsForAwait | `suspend fun <K, V> KafkaConsumer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.partitionsFor
pauseAwait | `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
pausedAwait | `suspend fun <K, V> KafkaConsumer<K, V>.pausedAwait(): Set<TopicPartition>` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.paused
pipeToAwait | `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
pollAwait | `suspend fun <K, V> KafkaConsumer<K, V>.pollAwait(timeout: Duration): KafkaConsumerRecords<K, V>` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.poll
positionAwait | `suspend fun <K, V> KafkaConsumer<K, V>.positionAwait(partition: TopicPartition): Long` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.position
resumeAwait | `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
seekAwait | `suspend fun <K, V> KafkaConsumer<K, V>.seekAwait(topicPartition: TopicPartition, offset: Long): Unit` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.seek
seekToBeginningAwait | `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
seekToEndAwait | `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
subscribeAwait | `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
subscriptionAwait | `suspend fun <K, V> KafkaConsumer<K, V>.subscriptionAwait(): Set<String>` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.subscription
unsubscribeAwait | `suspend fun <K, V> KafkaConsumer<K, V>.unsubscribeAwait(): Unit` Suspending version of method io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe