PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "nhillklrpedtvuhr")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "xvwkshkkryqlcbmn")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "fcamoifbyffusemh")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "nxoisaqlysuieurv")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "hyixjgyikmsaxsbh")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "uvvtlgyekirccled")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "xpunmgubhpbhmwue")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "mknhktiodtbliymc")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "onxbfcivrgxtvebn")
suspend fun topicName(value: Output<String>)
@JvmName(name = "kiqxrodmscemsfeu")
suspend fun topicName(value: String)