PipeSourceSelfManagedKafkaParametersArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "utlyegjjigwvonpp")
suspend fun additionalBootstrapServers(value: Output<List<String>>)
@JvmName(name = "bpoavmhqslsrgfhc")
suspend fun additionalBootstrapServers(vararg values: Output<String>)
@JvmName(name = "lgotmdwgweavgalj")
suspend fun additionalBootstrapServers(vararg values: String)
@JvmName(name = "bqlhjuheaclwdmoj")
suspend fun additionalBootstrapServers(values: List<Output<String>>)
@JvmName(name = "pqlqdulctyqrqbyv")
suspend fun additionalBootstrapServers(value: List<String>?)
Link copied to clipboard
@JvmName(name = "jhunjjubpgnxuujr")
suspend fun batchSize(value: Output<Int>)
@JvmName(name = "cbamblekjyostdgm")
suspend fun batchSize(value: Int?)
Link copied to clipboard
@JvmName(name = "ygylarkykxhwivmo")
suspend fun consumerGroupId(value: Output<String>)
@JvmName(name = "psxejdyxrsfqklbv")
suspend fun consumerGroupId(value: String?)
Link copied to clipboard
@JvmName(name = "lqoaoqjvmuiyapch")
suspend fun credentials(value: Output<Any>)
@JvmName(name = "gvcelbbjqoklccvu")
suspend fun credentials(value: Any?)
Link copied to clipboard
@JvmName(name = "txmrnxouthxhpblw")
suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)
@JvmName(name = "ehofxdhvstxyloos")
suspend fun maximumBatchingWindowInSeconds(value: Int?)
Link copied to clipboard
@JvmName(name = "rapmyjnbikmmnvfd")
suspend fun serverRootCaCertificate(value: Output<String>)
@JvmName(name = "joqopotldivslkru")
suspend fun serverRootCaCertificate(value: String?)
Link copied to clipboard
@JvmName(name = "rdmylbhcqlatisfr")
suspend fun startingPosition(value: PipeSelfManagedKafkaStartPosition?)
@JvmName(name = "pstbxsdlqfyautdg")
suspend fun startingPosition(value: Output<PipeSelfManagedKafkaStartPosition>)
Link copied to clipboard
@JvmName(name = "engbhqmespxppikv")
suspend fun topicName(value: Output<String>)
@JvmName(name = "lkhyqoipadcffofr")
suspend fun topicName(value: String)
Link copied to clipboard
@JvmName(name = "odlnsldyjtkwrpug")
suspend fun vpc(value: PipeSelfManagedKafkaAccessConfigurationVpcArgs?)
@JvmName(name = "ckrxsmjdiiiuvilh")
suspend fun vpc(value: Output<PipeSelfManagedKafkaAccessConfigurationVpcArgs>)
@JvmName(name = "troopkjvdlstvkvo")
suspend fun vpc(argument: suspend PipeSelfManagedKafkaAccessConfigurationVpcArgsBuilder.() -> Unit)