DataflowEndpointKafka interface

Proprietà dell'endpoint Kafka

Proprietà

authentication

Configurazione dell'autenticazione. NOTA: è consentita solo la proprietà di autenticazione per ogni voce.

batching

Configurazione in batch.

cloudEventAttributes

Configurazione del mapping degli eventi cloud.

compression

Compressione. Può essere none, gzip, lz4 o snappy. Nessun effetto se l'endpoint viene usato come origine.

consumerGroupId

ID gruppo di consumer.

copyMqttProperties

Copiare le proprietà broker. Nessun effetto se l'endpoint viene usato come origine o se il flusso di dati non ha un'origine Broker.

host

Host endpoint Kafka.

kafkaAcks

Kafka acks. Può essere tutto, uno o zero. Nessun effetto se l'endpoint viene usato come origine.

partitionStrategy

Strategia di gestione delle partizioni. Può essere predefinito o statico. Nessun effetto se l'endpoint viene usato come origine.

tls

Configurazione tls.

Dettagli proprietà

authentication

Configurazione dell'autenticazione. NOTA: è consentita solo la proprietà di autenticazione per ogni voce.

authentication: DataflowEndpointKafkaAuthentication

Valore della proprietà

batching

Configurazione in batch.

batching?: DataflowEndpointKafkaBatching

Valore della proprietà

cloudEventAttributes

Configurazione del mapping degli eventi cloud.

cloudEventAttributes?: string

Valore della proprietà

string

compression

Compressione. Può essere none, gzip, lz4 o snappy. Nessun effetto se l'endpoint viene usato come origine.

compression?: string

Valore della proprietà

string

consumerGroupId

ID gruppo di consumer.

consumerGroupId?: string

Valore della proprietà

string

copyMqttProperties

Copiare le proprietà broker. Nessun effetto se l'endpoint viene usato come origine o se il flusso di dati non ha un'origine Broker.

copyMqttProperties?: string

Valore della proprietà

string

host

Host endpoint Kafka.

host: string

Valore della proprietà

string

kafkaAcks

Kafka acks. Può essere tutto, uno o zero. Nessun effetto se l'endpoint viene usato come origine.

kafkaAcks?: string

Valore della proprietà

string

partitionStrategy

Strategia di gestione delle partizioni. Può essere predefinito o statico. Nessun effetto se l'endpoint viene usato come origine.

partitionStrategy?: string

Valore della proprietà

string

tls

Configurazione tls.

tls?: TlsProperties

Valore della proprietà