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

DataflowEndpointKafkaArgsBuilder

class DataflowEndpointKafkaArgsBuilder

Builder for DataflowEndpointKafkaArgs.

Functions

authentication

@JvmName(name = "gtiyvysxgkoprpoa")

suspend fun authentication(value: DataflowEndpointKafkaAuthenticationArgs)

@JvmName(name = "lahoorrqcsgirxey")

suspend fun authentication(value: Output<DataflowEndpointKafkaAuthenticationArgs>)

@JvmName(name = "ovxevjrqwpbkdwoh")

suspend fun authentication(argument: suspend DataflowEndpointKafkaAuthenticationArgsBuilder.() -> Unit)

batching

@JvmName(name = "hifoteenhdgabnmw")

suspend fun batching(value: DataflowEndpointKafkaBatchingArgs?)

@JvmName(name = "vpbflrnoclwvfisg")

suspend fun batching(value: Output<DataflowEndpointKafkaBatchingArgs>)

@JvmName(name = "pppmadcjdlpcecop")

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

cloudEventAttributes

@JvmName(name = "edwffycgyaixevhc")

fun cloudEventAttributes(value: CloudEventAttributeType)

@JvmName(name = "vbscqnvarpvfdqga")

suspend fun cloudEventAttributes(value: Either<String, CloudEventAttributeType>?)

@JvmName(name = "xncayjlucptkuaix")

suspend fun cloudEventAttributes(value: Output<Either<String, CloudEventAttributeType>>)

@JvmName(name = "xyhxwegjvqkrmguf")

fun cloudEventAttributes(value: String)

compression

@JvmName(name = "bbysrlbnadffkpuk")

fun compression(value: DataflowEndpointKafkaCompression)

@JvmName(name = "uamwatagslnrksfq")

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

@JvmName(name = "slqsloqysglgkmjr")

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

@JvmName(name = "ljrcgmpgeqjcdvmm")

fun compression(value: String)

consumerGroupId

@JvmName(name = "lrymhxspufaicxfe")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "jrokppbejcllnmce")

suspend fun consumerGroupId(value: String?)

copyMqttProperties

@JvmName(name = "piiawifwltjjanud")

fun copyMqttProperties(value: OperationalMode)

@JvmName(name = "fbrljarfuyqkkabl")

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

@JvmName(name = "bulouayympjufmun")

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

@JvmName(name = "knqkjqvwyxcjxdlo")

fun copyMqttProperties(value: String)

host

@JvmName(name = "vdqhjpabldxhxhgp")

suspend fun host(value: Output<String>)

@JvmName(name = "vhytvifooiclawsn")

suspend fun host(value: String)

kafkaAcks

@JvmName(name = "silkjmlhbdogcjdc")

fun kafkaAcks(value: DataflowEndpointKafkaAcks)

@JvmName(name = "afgowqtrhruccyoi")

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

@JvmName(name = "osqxjlchltecqgcy")

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

@JvmName(name = "ucmnmoqttjmfxfxm")

fun kafkaAcks(value: String)

partitionStrategy

@JvmName(name = "ambbdfiksyfoicnm")

fun partitionStrategy(value: DataflowEndpointKafkaPartitionStrategy)

@JvmName(name = "lnmvmbkbenohtwvf")

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

@JvmName(name = "vjnmtxymhiuhunrv")

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

@JvmName(name = "twbndpmiibfjijbl")

fun partitionStrategy(value: String)

tls

@JvmName(name = "oshkvbykaplcvcwp")

suspend fun tls(value: TlsPropertiesArgs?)

@JvmName(name = "rufjoutmqslkfoqy")

suspend fun tls(value: Output<TlsPropertiesArgs>)

@JvmName(name = "llbukxfdqberaafc")

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