Kafka3ConnectionService¶
Descrição¶
Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor.
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 |
|
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 |
|
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 |
|
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.