connector-apache-kafka/com.river.connector.apache.kafka/MutableReceiverOptions/Subscription/Companion

Companion

object Companion

Functions

partitionAssignment

fun partitionAssignment(partitions: List<TopicPartition>): MutableReceiverOptions.Subscription

fun partitionAssignment(partition: TopicPartition, vararg partitions: TopicPartition): MutableReceiverOptions.Subscription

fun pattern(pattern: Pattern): MutableReceiverOptions.Subscription

fun topics(topics: List<String>): MutableReceiverOptions.Subscription

fun topics(topic: String, vararg topics: String): MutableReceiverOptions.Subscription