PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "yndmwbmljrgbvmmo")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "qyelnbehkvinsees")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "cblkujqjokdqbrnc")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "peaoxauvhhicbjat")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "tntshainlmaxbkjx")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "osyklrwceecdqtuf")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "dtkvrlbpwfkljrnl")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "lqqqftbighrsmbrl")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "tvwgarxkdnhrwbjb")
suspend fun topicName(value: Output<String>)
@JvmName(name = "iykmdnbcvwrmeqph")
suspend fun topicName(value: String)