Partilhar via


DataflowEndpointKafka interface

Propriedades do ponto final Kafka

Propriedades

authentication

Configuração de autenticação. NOTA - apenas a propriedade de autenticação é permitida por entrada.

batching

Configuração de lotes.

cloudEventAttributes

Configuração de mapeamento de eventos na nuvem.

compression

Compressão. Pode ser nenhum, gzip, lz4 ou snappy. Nenhum efeito se o endpoint for usado como fonte.

consumerGroupId

ID do grupo de consumidores.

copyMqttProperties

Copie as propriedades do Broker. Nenhum efeito se o ponto de extremidade for usado como uma fonte ou se o fluxo de dados não tiver uma fonte do Broker.

host

Host de ponto final Kafka.

kafkaAcks

Kafka acks. Pode ser tudo, um ou zero. Nenhum efeito se o endpoint for usado como fonte.

partitionStrategy

Estratégia de manipulação de partições. Pode ser padrão ou estático. Nenhum efeito se o endpoint for usado como fonte.

tls

Configuração TLS.

Detalhes de Propriedade

authentication

Configuração de autenticação. NOTA - apenas a propriedade de autenticação é permitida por entrada.

authentication: DataflowEndpointKafkaAuthentication

Valor de Propriedade

batching

Configuração de lotes.

batching?: DataflowEndpointKafkaBatching

Valor de Propriedade

cloudEventAttributes

Configuração de mapeamento de eventos na nuvem.

cloudEventAttributes?: string

Valor de Propriedade

string

compression

Compressão. Pode ser nenhum, gzip, lz4 ou snappy. Nenhum efeito se o endpoint for usado como fonte.

compression?: string

Valor de Propriedade

string

consumerGroupId

ID do grupo de consumidores.

consumerGroupId?: string

Valor de Propriedade

string

copyMqttProperties

Copie as propriedades do Broker. Nenhum efeito se o ponto de extremidade for usado como uma fonte ou se o fluxo de dados não tiver uma fonte do Broker.

copyMqttProperties?: string

Valor de Propriedade

string

host

Host de ponto final Kafka.

host: string

Valor de Propriedade

string

kafkaAcks

Kafka acks. Pode ser tudo, um ou zero. Nenhum efeito se o endpoint for usado como fonte.

kafkaAcks?: string

Valor de Propriedade

string

partitionStrategy

Estratégia de manipulação de partições. Pode ser padrão ou estático. Nenhum efeito se o endpoint for usado como fonte.

partitionStrategy?: string

Valor de Propriedade

string

tls

Configuração TLS.

tls?: TlsProperties

Valor de Propriedade