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

DataflowEndpointKafkaArgsBuilder

class DataflowEndpointKafkaArgsBuilder

Builder for DataflowEndpointKafkaArgs.

Functions

authentication

@JvmName(name = "lfikygguefysjndu")

suspend fun authentication(value: DataflowEndpointKafkaAuthenticationArgs)

@JvmName(name = "eflwxrkvglbmdrnp")

suspend fun authentication(value: Output<DataflowEndpointKafkaAuthenticationArgs>)

@JvmName(name = "fxpjsawbfohdpgse")

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

batching

@JvmName(name = "kjwsovmspkxgbrqd")

suspend fun batching(value: DataflowEndpointKafkaBatchingArgs?)

@JvmName(name = "jrmqxnrmnebradra")

suspend fun batching(value: Output<DataflowEndpointKafkaBatchingArgs>)

@JvmName(name = "ajonktddkampryjk")

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

cloudEventAttributes

@JvmName(name = "gvylneccigggycin")

fun cloudEventAttributes(value: CloudEventAttributeType)

@JvmName(name = "avfsxxfwqnomggnt")

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

@JvmName(name = "maswmfysdqptagqj")

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

@JvmName(name = "wqearhhnltgftuao")

fun cloudEventAttributes(value: String)

compression

@JvmName(name = "jahgbqumrvpyiyqy")

fun compression(value: DataflowEndpointKafkaCompression)

@JvmName(name = "bnngkqceduumsjqu")

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

@JvmName(name = "wffspwxnusagkqvi")

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

@JvmName(name = "sjpjmkhjchiisniw")

fun compression(value: String)

consumerGroupId

@JvmName(name = "dwxymyhubbwnrbij")

suspend fun consumerGroupId(value: Output<String>)

@JvmName(name = "ukrovmyshevfxtny")

suspend fun consumerGroupId(value: String?)

copyMqttProperties

@JvmName(name = "rcxgjdssrfaurggp")

fun copyMqttProperties(value: OperationalMode)

@JvmName(name = "sesyshfvhitbnhsn")

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

@JvmName(name = "ilswavviknlmfilp")

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

@JvmName(name = "rsmnvogalfoltdbl")

fun copyMqttProperties(value: String)

host

@JvmName(name = "aoeroavyxktouutp")

suspend fun host(value: Output<String>)

@JvmName(name = "vwavwpihchboqfiv")

suspend fun host(value: String)

kafkaAcks

@JvmName(name = "kxeinoiubmskmgrt")

fun kafkaAcks(value: DataflowEndpointKafkaAcks)

@JvmName(name = "ytbxraqbjmxwdsqh")

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

@JvmName(name = "hxwtjnqugdwkveua")

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

@JvmName(name = "btqlqbvxnmnnktpv")

fun kafkaAcks(value: String)

partitionStrategy

@JvmName(name = "ersrxjedavrubuyh")

fun partitionStrategy(value: DataflowEndpointKafkaPartitionStrategy)

@JvmName(name = "owimgeseocaqviga")

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

@JvmName(name = "ihdchoswrthmrhso")

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

@JvmName(name = "kmlqcerqjobhnlyl")

fun partitionStrategy(value: String)

tls

@JvmName(name = "ybymtoycrqghmtec")

suspend fun tls(value: TlsPropertiesArgs?)

@JvmName(name = "lfwnpimrwrqptawv")

suspend fun tls(value: Output<TlsPropertiesArgs>)

@JvmName(name = "hlmhirmbnqhaqdem")

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