Para agentes de IA: um índice de documentação está disponível em https://www.mongodb.com/pt-br/docs/llms.txt — as versões de marcação de todas as páginas estão disponíveis anexando .md a qualquer caminho de URL .
Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Menu Docs

Propriedades de processamento de mensagens do conector

Use as configurações nesta página para configurar o comportamento de processamento de mensagens do connector de pia MongoDB Kafka, incluindo o seguinte:

  • Tamanho do lote da mensagem

  • Limites de taxa

  • Número de tarefas paralelas

Para obter uma lista de definições de configuração do conector de coletor organizadas por categoria, consulte o guia sobre Propriedades de configuração do Connector de coletor.

Nome
Descrição

max.batch.size

Tipo: int

Descrição:
número máximo de registros de coletores em lote para processamento.

Considere o lote que contém os seguintes registros:

[ 1, 2, 3, 4, 5 ]

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

Quando definido 1 como, 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 registros como uma operação de gravação em massa ordenada ou não ordenada. Quando definido true para, o valor padrão, o conector escreve um lote de registros como uma operação de escrita em massa ordenada.

Para saber mais sobre operações de escrita em massa, consulte Operações de escrita 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 pia processa para acionar o tempo limite de limitação de taxa. Um valor de 0 significa que não há limitação de taxa.

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

rate.limiting.timeout

Tipo: int

Descrição:
quanto tempo (em milissegundos) deve ser aguardado antes que o conector do coletor retome o processamento depois de atingir o limite de limitação de taxa.

0
Padrão: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 puder lidar com o nível de paralelismo especificado.

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

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