fun consumerListener(consumerAdded: (id: String, consumer: Consumer<*, *>) -> Unit = { _, _ -> }, consumerRemoved: (id: String, consumer: Consumer<*, *>) -> Unit = { _, _ -> })

keyDeserializer

fun keyDeserializer(transform: (topic: String, data: ByteArray) -> K)

maxCommitAttempts

fun maxCommitAttempts(size: Int)

maxDeferredCommits

fun maxDeferredCommits(size: Int)

maxDelayRebalance

fun maxDelayRebalance(duration: Duration)

pollTimeout

fun pollTimeout(duration: Duration)

properties

fun properties(builder: PropertyBuilder.() -> Unit)

revokeListeners

fun revokeListeners(onRevoke: () -> Collection<ReceiverPartition>)

scheduler

fun scheduler(scheduler: () -> Scheduler)

subscription

fun subscription(f: MutableReceiverOptions.Subscription.Companion.() -> MutableReceiverOptions.Subscription)

toReceiverOptions

fun toReceiverOptions(): ReceiverOptions<K, V>

valueDeserializer

fun valueDeserializer(transform: (topic: String, data: ByteArray) -> V)