PipeSourceManagedStreamingKafkaParametersArgsBuilder

Functions

@JvmName(name = "xkiogfqsdvojnvrl")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "jswghiccwnsirajp")

suspend fun batchSize(value: Int?)

@JvmName(name = "rrhnoilajloeuffj")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "sejonffkgguyjhjf")

suspend fun consumerGroupId(value: String?)

@JvmName(name = "inahglvvsrhxaskk")

@JvmName(name = "ronpvjjsqrahxkna")

@JvmName(name = "lyeqwdqjihrnjvwc")

@JvmName(name = "gclalsepkkoasgqb")

@JvmName(name = "mvlpishwnrejtfoa")

@JvmName(name = "pwfslrleiqbatbym")

@JvmName(name = "mtlesmxdtdklgics")

@JvmName(name = "lakcisiawwbgepry")

@JvmName(name = "nlwwsdrftwdpgdlg")

suspend fun topicName(value: Output<String>)

@JvmName(name = "gjnwjiigluynqkhj")

suspend fun topicName(value: String)