pulumi-azure-native-kotlin/com.pulumi.azurenative.iotoperations.kotlin.inputs/DataFlowEndpointKafkaArgsBuilder

DataFlowEndpointKafkaArgsBuilder

class DataFlowEndpointKafkaArgsBuilder

Builder for DataFlowEndpointKafkaArgs.

Functions

batching

@JvmName(name = "fuhracvxdguhqgas")

suspend fun batching(value: DataFlowEndpointKafkaBatchingArgs?)

@JvmName(name = "mnyoqvocjsomuoxt")

suspend fun batching(value: Output<DataFlowEndpointKafkaBatchingArgs>)

@JvmName(name = "ekvowbwvabdqovap")

suspend fun batching(argument: suspend DataFlowEndpointKafkaBatchingArgsBuilder.() -> Unit)

compression

@JvmName(name = "jdhotvsukphrijbe")

fun compression(value: DataFlowEndpointKafkaCompression)

@JvmName(name = "vwnjvhkmnpwrvewe")

suspend fun compression(value: Either<String, DataFlowEndpointKafkaCompression>?)

@JvmName(name = "ubrckajtuonuxvbl")

suspend fun compression(value: Output<Either<String, DataFlowEndpointKafkaCompression>>)

@JvmName(name = "swnkskhadldaopqf")

fun compression(value: String)

consumerGroupId

@JvmName(name = "vkkhsfndiovlysng")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "tyfxurpslejffiag")

suspend fun consumerGroupId(value: String?)

copyMqttProperties

@JvmName(name = "ksjtjecgnigquyew")

fun copyMqttProperties(value: OperationalMode)

@JvmName(name = "qkfaffaokxcrtptu")

suspend fun copyMqttProperties(value: Either<String, OperationalMode>?)

@JvmName(name = "utmbqwfgxjqktlkm")

suspend fun copyMqttProperties(value: Output<Either<String, OperationalMode>>)

@JvmName(name = "xxamqvyfilttvyvy")

fun copyMqttProperties(value: String)

host

@JvmName(name = "oqolmilydxptqdhf")

suspend fun host(value: Output<String>)

@JvmName(name = "xdkshqyorxynbwxg")

suspend fun host(value: String?)

kafkaAcks

@JvmName(name = "xfvvwclfnugxlipn")

fun kafkaAcks(value: DataFlowEndpointKafkaAcks)

@JvmName(name = "qjqkvbjlwcpkparo")

suspend fun kafkaAcks(value: Either<String, DataFlowEndpointKafkaAcks>?)

@JvmName(name = "wcpqjuetvccahjwb")

suspend fun kafkaAcks(value: Output<Either<String, DataFlowEndpointKafkaAcks>>)

@JvmName(name = "tigebdccdlpnlomg")

fun kafkaAcks(value: String)

partitionStrategy

@JvmName(name = "camvliotwkykvcig")

fun partitionStrategy(value: DataFlowEndpointKafkaPartitionStrategy)

@JvmName(name = "yycnvsltxkklfhnh")

suspend fun partitionStrategy(value: Either<String, DataFlowEndpointKafkaPartitionStrategy>?)

@JvmName(name = "xoegqoyrnrbebibq")

suspend fun partitionStrategy(value: Output<Either<String, DataFlowEndpointKafkaPartitionStrategy>>)

@JvmName(name = "whsllempyxtajnsg")

fun partitionStrategy(value: String)

tls

@JvmName(name = "umhfdxkxlseqxtjr")

suspend fun tls(value: TlsPropertiesArgs)

@JvmName(name = "dtanrrjfbbwsptfg")

suspend fun tls(value: Output<TlsPropertiesArgs>)

@JvmName(name = "unasksmbonxvpppx")

suspend fun tls(argument: suspend TlsPropertiesArgsBuilder.() -> Unit)