Propriedades de processamento de mensagens do conector

max.batch.size

Tipo: int

Descrição:
Número máximo de registros de sink para agrupar em lote para em processamento.

Considere o lote que contém os seguintes registros:

[ 1, 2, 3, 4, 5 ]

Quando definido como 0, o conector executa uma única gravar em massa para todo o lote.

Quando definido como 1, o conector executa uma gravação em massa para cada registro no lote, para um total de cinco gravações em massa, conforme mostrado no exemplo a seguir:

[1], [2], [3], [4], [5]

Padrão: 0
Valores aceitos: um número inteiro

bulk.write.ordered

Tipo: booleano

descrição:
Se o conector grava um lote de registro como uma operação de gravação em massa ordenada ou não ordenada. Quando definido como true, o valor padrão, o conector grava um lote de registro como uma operação de gravação em massa ordenada.

Para **aprender** mais sobre operação de gravação em massa, consulte operação de gravação em massa.

padrão: true
Valores aceitos: true ou false

rate.limiting.every.n

Tipo: int

Descrição:
Número de lotes de registros que o conector de sink processa para trigger o tempo limite de limitação de taxa. Um valor de 0 significa que não há limitação de taxa.

Padrão: 0
Valores aceitos: um número inteiro

rate.limiting.timeout

Tipo: int

Descrição:
Quanto tempo (em milissegundos) esperar antes que o conector de sink deva retomar o processamento após atingir o limite de limitação de taxa.

Padrão: 0
Valores aceitos: Um número inteiro

tarefas.max

Tipo: int

Descrição:
O número máximo de tarefas a serem criadas para este conector. O conector pode criar menos do que o máximo de tarefas especificadas se não conseguir lidar com o nível de paralelismo especificado.

IMPORTANTE: Se você especificar um valor maior que 1, o conector habilitará o processamento paralelo das tarefas. Se o seu tópico tiver vários logs de partição, o que permite que o conector leia o tópico em paralelo, as tarefas poderão processar as mensagens fora de ordem.

Padrão: 1
Valores aceitos: um número inteiro