ArmIotOperationsModelFactory.DataflowEndpointKafka Method

Definition

Namespace:

Azure.ResourceManager.IotOperations.Models

Assembly:

Azure.ResourceManager.IotOperations.dll

Package:

Azure.ResourceManager.IotOperations v1.1.0

Source:

ArmIotOperationsModelFactory.cs

public static Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafka DataflowEndpointKafka(Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaAuthentication authentication = default, string consumerGroupId = default, string host = default, Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaBatching batching = default, Azure.ResourceManager.IotOperations.Models.IotOperationsOperationalMode? copyMqttProperties = default, Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaCompression? compression = default, Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaAck? kafkaAcks = default, Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaPartitionStrategy? partitionStrategy = default, Azure.ResourceManager.IotOperations.Models.IotOperationsTlsProperties tls = default, Azure.ResourceManager.IotOperations.Models.CloudEventAttributeType? cloudEventAttributes = default);

static member DataflowEndpointKafka : Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaAuthentication * string * string * Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaBatching * Nullable<Azure.ResourceManager.IotOperations.Models.IotOperationsOperationalMode> * Nullable<Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaCompression> * Nullable<Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaAck> * Nullable<Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafkaPartitionStrategy> * Azure.ResourceManager.IotOperations.Models.IotOperationsTlsProperties * Nullable<Azure.ResourceManager.IotOperations.Models.CloudEventAttributeType> -> Azure.ResourceManager.IotOperations.Models.DataflowEndpointKafka

Public Shared Function DataflowEndpointKafka (Optional authentication As DataflowEndpointKafkaAuthentication = Nothing, Optional consumerGroupId As String = Nothing, Optional host As String = Nothing, Optional batching As DataflowEndpointKafkaBatching = Nothing, Optional copyMqttProperties As Nullable(Of IotOperationsOperationalMode) = Nothing, Optional compression As Nullable(Of DataflowEndpointKafkaCompression) = Nothing, Optional kafkaAcks As Nullable(Of DataflowEndpointKafkaAck) = Nothing, Optional partitionStrategy As Nullable(Of DataflowEndpointKafkaPartitionStrategy) = Nothing, Optional tls As IotOperationsTlsProperties = Nothing, Optional cloudEventAttributes As Nullable(Of CloudEventAttributeType) = Nothing) As DataflowEndpointKafka

Parameters

authentication

DataflowEndpointKafkaAuthentication

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

consumerGroupId

String

Consumer group ID.

host

String

Kafka endpoint host.

batching

DataflowEndpointKafkaBatching

Batching configuration.

copyMqttProperties

Nullable<IotOperationsOperationalMode>

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

compression

Nullable<DataflowEndpointKafkaCompression>

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

kafkaAcks

Nullable<DataflowEndpointKafkaAck>

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

partitionStrategy

Nullable<DataflowEndpointKafkaPartitionStrategy>

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

tls

IotOperationsTlsProperties

TLS configuration.

cloudEventAttributes

Nullable<CloudEventAttributeType>

Cloud event mapping config.

Returns

DataflowEndpointKafka

A new DataflowEndpointKafka instance for mocking.