Kafka3ConnectionService

Descrição

Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor.

Tags

kafka, openflow

Propriedades

Na lista abaixo, as propriedades obrigatórias são mostradas com um asterisco (*). Outras propriedades são consideradas opcionais. A tabela também indica os valores padrão e se uma propriedade é compatível com linguagem de expressão NiFi.

Nome de exibição

Nome da API

Valor padrão

Valores permitidos

Descrição

Serviço de contexto SSL

Serviço de contexto SSL

Serviço de suporte à comunicação SSL com os corretores Kafka

Tempo de espera de confirmação *

ack.wait.time

5 s

Após enviar uma mensagem ao Kafka, isso indica o tempo que o serviço aguardará uma resposta dele. Se o Kafka não confirmar a mensagem dentro desse período, o serviço lançará uma exceção.

Servidores de bootstrap *

bootstrap.servers

Lista separada por vírgulas de servidores bootstrap Kafka no formato host:port. Corresponde à propriedade bootstrap.servers do Kafka

Tempo limite do cliente *

default.api.timeout.ms

60 s

Tempo limite padrão para operações do cliente Kafka. Mapeado para o Kafka default.api.timeout.ms. A propriedade Kafka request.timeout.ms é derivada da metade do tempo limite configurado

Nível de isolamento da transação *

isolation.level

read_committed

  • Leitura confirmada

  • Leitura não confirmada

Especifica como o serviço deve lidar com os níveis de isolamento de transação ao se comunicar com o Kafka. A opção não confirmada significa que as mensagens serão recebidas assim que forem gravadas no Kafka, mas o pull delas será efetuado, mesmo que o produtor cancele as transações. A opção confirmada configura o serviço para não receber nenhuma mensagem cuja transação do produtor tenha sido cancelada, mas isso pode resultar em alguma latência, pois o consumidor deve esperar que o produtor termine toda a transação em vez de efetuar pull à medida que as mensagens se tornam disponíveis. Corresponde à propriedade isolation.level do Kafka.

Tempo máximo de espera dos metadados *

max.block.ms

5 s

A quantidade de tempo que o editor aguardará para obter metadados ou aguardar a descarga do buffer durante a chamada “send” antes de falhar em toda a chamada “send”. Corresponde à propriedade max.block.ms do Kafka

Máximo de registros por pesquisa *

max.poll.records

10000

Número máximo de registros que o Kafka deve retornar em uma única pesquisa.

Mecanismo SASL *

sasl.mechanism

GSSAPI

  • GSSAPI

  • PLAIN

  • SCRAM-SHA-256

  • SCRAM-SHA-512

Mecanismo SASL usado para autenticação. Corresponde à propriedade sasl.mechanism do cliente Kafka

Senha SASL *

sasl.password

Senha fornecida com o nome de usuário configurado ao usar os mecanismos PLAIN ou SCRAM SASL

Nome de usuário SASL *

sasl.username

Nome de usuário fornecido com a senha configurada ao usar os mecanismos PLAIN ou SCRAM SASL

Protocolo de segurança *

security.protocol

PLAINTEXT

  • PLAINTEXT

  • SSL

  • SASL_PLAINTEXT

  • SASL_SSL

Protocolo de segurança usado para se comunicar com os corretores. Corresponde à propriedade security.protocol do cliente Kafka

Gerenciamento do estado

Esse componente não armazena o estado.

Restrito

Esse componente não é restrito.

Considerações sobre os recursos do sistema

Esse componente não especifica considerações sobre os recursos do sistema.