PipeSourceManagedStreamingKafkaParametersArgsBuilder

Functions

@JvmName(name = "pukomggcbpvklwtk")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "ipolpgwfrpjkvshh")

suspend fun batchSize(value: Int?)

@JvmName(name = "rompbqckdywchpef")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "ayghduhoboisfdin")

suspend fun consumerGroupId(value: String?)

@JvmName(name = "oxitquwlfxxrhrhe")

@JvmName(name = "bbkwdtxxawcarisd")

@JvmName(name = "etjllumgeewraled")

@JvmName(name = "vpjoiypfqvgvxkjh")

@JvmName(name = "blakqeamhghcksgw")

@JvmName(name = "daoasoxxvpriudxr")

@JvmName(name = "bmlhtlcrqrfyndbv")

@JvmName(name = "jgtyypwojiqaaicr")

@JvmName(name = "yxfjhvjrcmbkjxuh")

suspend fun topicName(value: Output<String>)

@JvmName(name = "qcyswugrcawpaawt")

suspend fun topicName(value: String)