Share via

DataflowEndpointKafka interface

  • Reference
Package:
@azure/arm-iotoperations

Kafka endpoint properties

Properties

authentication

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

Batching configuration.
cloudEventAttributes

Cloud event mapping config.
compression

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

Consumer group ID.
copyMqttProperties

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

Kafka endpoint host.
kafkaAcks

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

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

TLS configuration.

Property Details

authentication

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

authentication: DataflowEndpointKafkaAuthentication

Property Value

DataflowEndpointKafkaAuthentication

batching

Batching configuration.

batching?: DataflowEndpointKafkaBatching

Property Value

DataflowEndpointKafkaBatching

cloudEventAttributes

Cloud event mapping config.

cloudEventAttributes?: string

Property Value

string

compression

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

compression?: string

Property Value

string

consumerGroupId

Consumer group ID.

consumerGroupId?: string

Property Value

string

copyMqttProperties

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

copyMqttProperties?: string

Property Value

string

host

Kafka endpoint host.

host: string

Property Value

string

kafkaAcks

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

kafkaAcks?: string

Property Value

string

partitionStrategy

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

partitionStrategy?: string

Property Value

string

tls

TLS configuration.

tls?: TlsProperties

Property Value

TlsProperties