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

DataflowEndpointKafkaArgs

data class DataflowEndpointKafkaArgs(val authentication: Output<DataflowEndpointKafkaAuthenticationArgs>, val batching: Output<DataflowEndpointKafkaBatchingArgs>? = null, val cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null, val compression: Output<Either<String, DataflowEndpointKafkaCompression>>? = null, val consumerGroupId: Output<String>? = null, val copyMqttProperties: Output<Either<String, OperationalMode>>? = null, val host: Output<String>, val kafkaAcks: Output<Either<String, DataflowEndpointKafkaAcks>>? = null, val partitionStrategy: Output<Either<String, DataflowEndpointKafkaPartitionStrategy>>? = null, val tls: Output<TlsPropertiesArgs>? = null) : ConvertibleToJava<DataflowEndpointKafkaArgs>

Kafka endpoint properties

Constructors

DataflowEndpointKafkaArgs

constructor(authentication: Output<DataflowEndpointKafkaAuthenticationArgs>, batching: Output<DataflowEndpointKafkaBatchingArgs>? = null, cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null, compression: Output<Either<String, DataflowEndpointKafkaCompression>>? = null, consumerGroupId: Output<String>? = null, copyMqttProperties: Output<Either<String, OperationalMode>>? = null, host: Output<String>, kafkaAcks: Output<Either<String, DataflowEndpointKafkaAcks>>? = null, partitionStrategy: Output<Either<String, DataflowEndpointKafkaPartitionStrategy>>? = null, tls: Output<TlsPropertiesArgs>? = null)

Properties

val authentication: Output<DataflowEndpointKafkaAuthenticationArgs>

Authentication configuration. NOTE - only authentication property is allowed per entry.

val batching: Output<DataflowEndpointKafkaBatchingArgs>? = null

Batching configuration.

cloudEventAttributes

val cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null

Cloud event mapping config.

val compression: Output<Either<String, DataflowEndpointKafkaCompression>>? = null

Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.

consumerGroupId

val consumerGroupId: Output<String>? = null

Consumer group ID.

copyMqttProperties

val copyMqttProperties: Output<Either<String, OperationalMode>>? = null

Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.

val host: Output<String>

Kafka endpoint host.

val kafkaAcks: Output<Either<String, DataflowEndpointKafkaAcks>>? = null

Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.

partitionStrategy

val partitionStrategy: Output<Either<String, DataflowEndpointKafkaPartitionStrategy>>? = null

Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.

val tls: Output<TlsPropertiesArgs>? = null

TLS configuration.

Functions

open override fun toJava(): DataflowEndpointKafkaArgs