PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "clwsslekjtnujkej")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "tvukhgkuormmqlyw")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "nwmyqbnedcxiuaqx")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "utngdkmyjghoblap")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "ipqklxbgujrjjxka")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "txoulxmrxwjfgkbq")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "xitvpjaltenmnopx")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "hcivkopvrgsyiece")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "gmdqfqtjxrtawgru")
suspend fun topicName(value: Output<String>)
@JvmName(name = "uquqhqvawarcqoho")
suspend fun topicName(value: String)