pulumi-azure-native-kotlin/com.pulumi.azurenative.iotoperations.kotlin.outputs/DataFlowEndpointKafkaResponse

DataFlowEndpointKafkaResponse

data class DataFlowEndpointKafkaResponse(val batching: DataFlowEndpointKafkaBatchingResponse? = null, val compression: String? = null, val consumerGroupId: String? = null, val copyMqttProperties: String? = null, val host: String? = null, val kafkaAcks: String? = null, val partitionStrategy: String? = null, val tls: TlsPropertiesResponse)

Kafka endpoint properties

Constructors

DataFlowEndpointKafkaResponse

constructor(batching: DataFlowEndpointKafkaBatchingResponse? = null, compression: String? = null, consumerGroupId: String? = null, copyMqttProperties: String? = null, host: String? = null, kafkaAcks: String? = null, partitionStrategy: String? = null, tls: TlsPropertiesResponse)

Types

object Companion

Properties

val batching: DataFlowEndpointKafkaBatchingResponse? = null

Batching configuration.

val compression: String? = null

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

consumerGroupId

val consumerGroupId: String? = null

Consumer group ID.

copyMqttProperties

val copyMqttProperties: String? = 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: String? = null

Kafka endpoint host.

val kafkaAcks: String? = null

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

partitionStrategy

val partitionStrategy: String? = null

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

val tls: TlsPropertiesResponse

TLS configuration.