PipeSourceManagedStreamingKafkaParametersArgsBuilder

Functions

@JvmName(name = "hjswgifkhteslsvj")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "qyvtyfgnhwbwqnyq")

suspend fun batchSize(value: Int?)

@JvmName(name = "dovnylacbjihayws")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "ovplittdsksfkujr")

suspend fun consumerGroupId(value: String?)

@JvmName(name = "cxaimmibukykkfwh")

@JvmName(name = "qllojaeyijivefuv")

@JvmName(name = "gdplydlwegdvgybl")

@JvmName(name = "jfhbvnxyjrmyqnyn")

@JvmName(name = "uhubkhlinqfvopco")

@JvmName(name = "vtrscubgxgilvdug")

@JvmName(name = "hwfmmmnngtnjgfoy")

@JvmName(name = "gilwcbqpnnojtqog")

@JvmName(name = "oluaotlmswwvsawa")

suspend fun topicName(value: Output<String>)

@JvmName(name = "miyhwjabqstfkmna")

suspend fun topicName(value: String)