PipeSourceParametersManagedStreamingKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "dvduyydvllnigcii")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "jsmdvinpvcnalvwu")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "bpishqkdlpxrnsvq")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "tjmqqwshgiwxgpvx")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "ibfnutknqayhiqfj")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "ohcrnpwrlkisudqe")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "cfyotylkbodeieml")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "xwbgdbujfuxbglld")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "gdavxhfnhdctbawh")
suspend fun topicName(value: Output<String>)
@JvmName(name = "ucoxrniqrwdfoopf")
suspend fun topicName(value: String)