PipeSourceSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "pcyxhdctdjjdegmm")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "qtrtcrgxeleriojc")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "jihfqkcopxjuinlg")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "kkbkxtxegboxosfh")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "pnwqvvhauwqjhssn")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "cxfuucjpvnmdbleh")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "kdliegnnpdedoxah")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "dydvoqypmpqsnsys")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "ynmlygevjwsfbuwi")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "dwuocfhhhrmlunmu")
suspend fun credentials(value: Output<Any>)
@JvmName(name = "msvsjrdovmnbtdnl")
suspend fun credentials(value: Any?)
Link copied to clipboard
@JvmName(name = "edpyohrtetwjmqsn")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "jlboljjvfrhowygh")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "yureaeutedpnbhak")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "pvphprfvqkpjvsbo")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "nplpucdqmudqsjkn")
suspend fun startingPosition(value: PipeSelfManagedKafkaStartPosition?)
@JvmName(name = "qwrgmfchcrrdkmyr")
suspend fun startingPosition(value: Output<PipeSelfManagedKafkaStartPosition>)
Link copied to clipboard
@JvmName(name = "lyenfbhrnfhobaid")
suspend fun topicName(value: Output<String>)
@JvmName(name = "xkjdvxhvvphavylu")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "bbctjdfpsoayklmf")
suspend fun vpc(value: PipeSelfManagedKafkaAccessConfigurationVpcArgs?)
@JvmName(name = "mektnbjvyrtwtgcb")
suspend fun vpc(value: Output<PipeSelfManagedKafkaAccessConfigurationVpcArgs>)
@JvmName(name = "mfwgwdhkbaphqldu")
suspend fun vpc(argument: suspend PipeSelfManagedKafkaAccessConfigurationVpcArgsBuilder.() -> Unit)