PipeSourceSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "cbxtdatqyyrmwapy")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "xcraviquaqjbspem")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "hpxlinjwsxerujym")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "kohwslexkrxqguhd")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "frorrqbmhgsstxcw")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "rywevdcsmylxaojo")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "gubthwfavvmxcifo")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "wnxlabvsbtmcdcwv")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "lonitkqumfpxwsax")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "xbnqafnsffllfufe")
suspend fun credentials(value: Output<Any>)
@JvmName(name = "almnpniqoexglguy")
suspend fun credentials(value: Any?)
Link copied to clipboard
@JvmName(name = "dtlqtocewslxoxkq")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "ixkxjgrjsosstdqj")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "csgbkcxvxkbchftq")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "llkynbhljabgemfu")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "vjfypkgwbscwxkbv")
suspend fun startingPosition(value: PipeSelfManagedKafkaStartPosition?)
@JvmName(name = "txayuclkuwwytavr")
suspend fun startingPosition(value: Output<PipeSelfManagedKafkaStartPosition>)
Link copied to clipboard
@JvmName(name = "swfmbdgkgbmqrjsa")
suspend fun topicName(value: Output<String>)
@JvmName(name = "dndhtajavuirdgdv")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "nifxaibxaihaebdq")
suspend fun vpc(value: PipeSelfManagedKafkaAccessConfigurationVpcArgs?)
@JvmName(name = "pxkadlmimlanqfeo")
suspend fun vpc(value: Output<PipeSelfManagedKafkaAccessConfigurationVpcArgs>)
@JvmName(name = "unedmjxnjcsvjnbf")
suspend fun vpc(argument: suspend PipeSelfManagedKafkaAccessConfigurationVpcArgsBuilder.() -> Unit)