PipeSourceManagedStreamingKafkaParametersArgsBuilder

Functions

@JvmName(name = "anpemdtlusipgjut")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "ibexjxeeheoitduk")

suspend fun batchSize(value: Int?)

@JvmName(name = "yonhpateollrremr")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "hvfgrppgbypikeuk")

suspend fun consumerGroupId(value: String?)

@JvmName(name = "veprerboxnycufhm")

@JvmName(name = "horwetrpexhntgqd")

@JvmName(name = "iomufpsxpatwhmqg")

@JvmName(name = "dtddkfiruxnohtxl")

@JvmName(name = "lwmgrnkmftjlfegx")

@JvmName(name = "tncxasuankhobjde")

@JvmName(name = "kslgjumkulnlstge")

@JvmName(name = "wrjknkypqhlxschl")

@JvmName(name = "seafyftdkiaccbdp")

suspend fun topicName(value: Output<String>)

@JvmName(name = "ltrlfwcohmyecvqo")

suspend fun topicName(value: String)