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