PipeSourceParametersSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "lulpocwogmdvepif")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "cvmligdhwiebttar")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "vewjwkodcnxfpyqg")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "ouwdbklynmuuwhtm")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "nbdyixmcnsinjajr")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "embnmmyjtamgkbab")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "ndgecdlshbuwfjvt")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "qttsvuajocehsmdv")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "iewrkuhepajqpmvh")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "rqulqstjwceosctc")
suspend fun credentials(value: Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs>)
@JvmName(name = "fogxqusajviulqdu")
suspend fun credentials(argument: suspend PipeSourceParametersSelfManagedKafkaParametersCredentialsArgsBuilder.() -> Unit)
Link copied to clipboard
@JvmName(name = "pubdqnnplunqjaba")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "jwsfofagfwxellqp")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "gmpyosliclbblqgq")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "ivchcurxbncobxlx")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "tymspbqevmmynawc")
suspend fun startingPosition(value: Output<String>)
@JvmName(name = "kiehlpvstaqwijgd")
suspend fun startingPosition(value: String?)
Link copied to clipboard
@JvmName(name = "sdpfdtmywhlvghbf")
suspend fun topicName(value: Output<String>)
@JvmName(name = "hgwhdwxdskfmnxoj")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "iulyqtfhugmhbbwm")
suspend fun vpc(value: PipeSourceParametersSelfManagedKafkaParametersVpcArgs?)
@JvmName(name = "kfgptpcqbmkiixqh")
suspend fun vpc(value: Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs>)
@JvmName(name = "leaavekrovmvvbfe")
suspend fun vpc(argument: suspend PipeSourceParametersSelfManagedKafkaParametersVpcArgsBuilder.() -> Unit)