connector-apache-kafka/com.river.connector.apache.kafka/MutableSenderOptions

MutableSenderOptions

class MutableSenderOptions<K, V>(props: Map<String, Any> = mutableMapOf())

Constructors

constructor(props: Map<String, Any> = mutableMapOf())

Functions

closeTimeout

fun closeTimeout(closeTimeout: Duration)

keySerializer

fun keySerializer(transform: (topic: String, key: K) -> ByteArray)

listener

fun listener(added: (id: String, producer: Producer<*, *>) -> Unit = { _, _ -> }, removed: (id: String, producer: Producer<*, *>) -> Unit = { _, _ -> })

maxInFlight

fun maxInFlight(maxInFlight: Int)

properties

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

scheduler

fun scheduler(scheduler: () -> Scheduler)

stopOnError

fun stopOnError(stopOnError: Boolean = true)

toSenderOptions

fun toSenderOptions(): SenderOptions<K, V>

valueSerializer

fun valueSerializer(transform: (topic: String, value: V) -> ByteArray)