pulumi-aws-native-kotlin/com.pulumi.awsnative.pipes.kotlin.inputs/PipeSourceSelfManagedKafkaParametersArgsBuilder

PipeSourceSelfManagedKafkaParametersArgsBuilder

class PipeSourceSelfManagedKafkaParametersArgsBuilder

Builder for PipeSourceSelfManagedKafkaParametersArgs.

Functions

additionalBootstrapServers

@JvmName(name = "atcqbqxuuvekdaln")

suspend fun additionalBootstrapServers(value: Output<List<String>>)

@JvmName(name = "vclcgwtjsxfpryjp")

suspend fun additionalBootstrapServers(vararg values: Output<String>)

@JvmName(name = "uwjchtcirtwjwccn")

suspend fun additionalBootstrapServers(vararg values: String)

@JvmName(name = "cayelqesnetokbls")

suspend fun additionalBootstrapServers(values: List<Output<String>>)

@JvmName(name = "iwbdxaxvdldwsodj")

suspend fun additionalBootstrapServers(value: List<String>?)

batchSize

@JvmName(name = "ayowoklvljecdifs")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "ftccrasjmsuxfskv")

suspend fun batchSize(value: Int?)

consumerGroupId

@JvmName(name = "nsvcobfiruqwtfnc")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "sioujrqjukfnvqbt")

suspend fun consumerGroupId(value: String?)

credentials

@JvmName(name = "kboeukuevpjuuaul")

suspend fun credentials(value: Output<Any>)

@JvmName(name = "jpdrslfpbssxrjwc")

suspend fun credentials(value: Any?)

maximumBatchingWindowInSeconds

@JvmName(name = "lunrhueequapsvee")

suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)

@JvmName(name = "eldugxhbqukmglra")

suspend fun maximumBatchingWindowInSeconds(value: Int?)

serverRootCaCertificate

@JvmName(name = "yswjkoeapmwvmejb")

suspend fun serverRootCaCertificate(value: Output<String>)

@JvmName(name = "xhjxwpidqcgcdqmq")

suspend fun serverRootCaCertificate(value: String?)

startingPosition

@JvmName(name = "xkkgpmaceijreocn")

suspend fun startingPosition(value: PipeSelfManagedKafkaStartPosition?)

@JvmName(name = "udhtytgjwplvbmom")

suspend fun startingPosition(value: Output<PipeSelfManagedKafkaStartPosition>)

topicName

@JvmName(name = "ekbyakxqepbxyhri")

suspend fun topicName(value: Output<String>)

@JvmName(name = "taccgiwhvhnnlnfe")

suspend fun topicName(value: String)

vpc

@JvmName(name = "qaygvpkjvfpmjebl")

suspend fun vpc(value: PipeSelfManagedKafkaAccessConfigurationVpcArgs?)

@JvmName(name = "tlicecxdqrgcqyvk")

suspend fun vpc(value: Output<PipeSelfManagedKafkaAccessConfigurationVpcArgs>)

@JvmName(name = "fvtemfdkoipwhuei")

suspend fun vpc(argument: suspend PipeSelfManagedKafkaAccessConfigurationVpcArgsBuilder.() -> Unit)