PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "sdqgwvvtceotccef")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "ewumgqgfxmqfdgrv")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "kirgadwiwubtjymp")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "msoyfgnevmjarryq")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "mougavxuciswxjid")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "nbyeoijytgtmdwjw")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "mvgysopavhxaidqw")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "ldniavmxhphhuyyt")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "okutnspmudeiegym")
suspend fun topicName(value: Output<String>)
@JvmName(name = "xfntiqopthtpdtvr")
suspend fun topicName(value: String)