PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "hgeidxixqffrxgar")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "eorkdeteiydkyyrn")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "ideitwktdfmggrsv")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "aixaeevgcxisanmt")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "yroiqmnjxqcbxthc")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "qylenjcjbnllxawr")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "lduxwcubexnbuhcu")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "fsakohcugelblfhw")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "hqgqgtwirrmyuqwd")
suspend fun topicName(value: Output<String>)
@JvmName(name = "uifibvvffqacmuke")
suspend fun topicName(value: String)