PipeSourceManagedStreamingKafkaParametersArgsBuilder

Functions

@JvmName(name = "owveylxgjxepdmsm")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "hkpilxfbxlqsjlbp")

suspend fun batchSize(value: Int?)

@JvmName(name = "sxyhkkgwwiagtilx")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "lalqiutogmmkpteo")

suspend fun consumerGroupId(value: String?)

@JvmName(name = "hgqvabvstacuoxsj")

@JvmName(name = "ripvgsludjuisetu")

@JvmName(name = "oopgpsponnfkujqj")

@JvmName(name = "lymonkovypdbukge")

@JvmName(name = "cphtcqdffgeftlbq")

@JvmName(name = "nghpdbxxrsmqobby")

@JvmName(name = "penotfwgktfmqtao")

@JvmName(name = "dladvhftukxbcivm")

@JvmName(name = "tiephwlutixkkgaj")

suspend fun topicName(value: Output<String>)

@JvmName(name = "mgpudsnnfsubdcbi")

suspend fun topicName(value: String)