PipeSourceParametersSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "lntveihwqsennfol")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "vckujapyfakdfity")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "jnvdkevvfjjdamqa")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "yqnomqoafancqhba")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "srvjithpxuihypaa")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "hbgmwhbtapxkomya")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "pwuvgmhrtigvulsp")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "soyfyhnorxwsgsag")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "frplxhjtaqwsoyqy")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "gwsbhmhxbdrmvnva")
suspend fun credentials(value: Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs>)
@JvmName(name = "nlphoxtextmmjhnx")
suspend fun credentials(argument: suspend PipeSourceParametersSelfManagedKafkaParametersCredentialsArgsBuilder.() -> Unit)
Link copied to clipboard
@JvmName(name = "llhmltqlpmncbsjh")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "nsklgbthnqpfswqd")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "aqemmltcxmmklmsf")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "onrylhfvkrbpqgno")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "alxbighmtbsoijvp")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "eipuognfqwtcvjdm")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "qhkaeeqwsbhmhgxc")
suspend fun topicName(value: Output<String>)
@JvmName(name = "laynbkgjkcooeaip")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "cfrituvkdgylifqc")
suspend fun vpc(value: PipeSourceParametersSelfManagedKafkaParametersVpcArgs?)
@JvmName(name = "xbqevvljfyebnchn")
suspend fun vpc(value: Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs>)
@JvmName(name = "fouptmlplnwdanom")
suspend fun vpc(argument: suspend PipeSourceParametersSelfManagedKafkaParametersVpcArgsBuilder.() -> Unit)