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. |
| cloud |
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. |
| consumer |
ID do grupo de consumidores. |
| copy |
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. |
| kafka |
Kafka acks. Pode ser tudo, um ou zero. Nenhum efeito se o endpoint for usado como fonte. |
| partition |
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