PipeSourceSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "jhpksyygjelaytfi")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "pfngcjqyiqdjhnjk")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "ikhfrngpjnivuoaq")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "sfdqqmbkksovjqfj")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "ntmdhkaphteuvvik")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "riaictxlygjhptwc")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "vvtmedpbmhxcjhof")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "ovagkohscdtjgbxh")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "unkqcxgbwnslhrds")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "yiskykjjvigrllbu")
suspend fun credentials(value: Output<Any>)
@JvmName(name = "oxwceenpevhlyubf")
suspend fun credentials(value: Any?)
Link copied to clipboard
@JvmName(name = "tpbvlxrbanqrurco")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "ndrekuoskxikehwg")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "gvvidqxvayvdfjhr")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "qkilqqpcvlyeqbmw")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "lpaltmhqwpttjwam")
suspend fun startingPosition(value: PipeSelfManagedKafkaStartPosition?)
@JvmName(name = "thvvrxepvgmwruit")
suspend fun startingPosition(value: Output<PipeSelfManagedKafkaStartPosition>)
Link copied to clipboard
@JvmName(name = "ybsjrgexixqrrktu")
suspend fun topicName(value: Output<String>)
@JvmName(name = "hojrhenpernrgmhb")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "oxlnlmsfprcccstk")
suspend fun vpc(value: PipeSelfManagedKafkaAccessConfigurationVpcArgs?)
@JvmName(name = "cebytxoxjgimaumn")
suspend fun vpc(value: Output<PipeSelfManagedKafkaAccessConfigurationVpcArgs>)
@JvmName(name = "rpkbikfrvbpxdxia")
suspend fun vpc(argument: suspend PipeSelfManagedKafkaAccessConfigurationVpcArgsBuilder.() -> Unit)