Apache Kafka

Clique com o botão direito na árvore ▸ Adicionar ▸ Pedido Kafka.

Configuração comum

Campo	Função
URL	A lista dos brokers, separados por vírgulas: hote1:9092,hote2:9092 — a cadeia inteira é resolvida pelo Handlebars antes de ser dividida
ID do cliente	O clientId anunciado aos brokers
Tópico	O tópico, qualquer que seja o modo
Modo	produce, consume ou browse

Autenticação

Campo	Valores
Mecanismo SASL	none, plain, scram-sha-256, scram-sha-512
Utilizador SASL / Palavra-passe SASL	A palavra-passe aceita um valor do tipo Segredo
TLS	Ativável de forma independente — um broker em TLS sem SASL funciona com o mecanismo none

Modo produce

Chave, valor, cabeçalhos do registo e, opcionalmente, partição. Sem partição explícita, aplica-se o particionador predefinido da biblioteca cliente. A resposta devolve os metadados do registo escrito: tópico, partição, offset.

Modo consume

Campo	Função
Grupo	O groupId do consumidor
Offset inicial	earliest, latest ou specific
Offset específico	Uma cadeia — os offsets do Kafka são inteiros de 64 bits
Partições	Um filtro do lado do cliente: a atribuição às partições continua a ser feita pelo grupo

Modo browse

Inspeciona uma partição sem grupo de consumidores: o Restorm recolhe dela um número limitado de mensagens e depois desliga-se. Neste modo, a partição é obrigatória.

É a ferramenta certa para ver o que existe num tópico sem criar um grupo nem deslocar um offset.

Num cenário

• Produção Kafka — ação unitária, devolve os metadados do registo;
• Consumo Kafka — subscreve através do grupo de consumidores e emite um evento por mensagem;
• Fecho da ligação Kafka — para o consumo.

Consulte Ligações e fluxos.

Fragmentos de código

Cinco alvos: JavaScript (kafkajs, em produção e em consumo) e kcat (produção, consumo, inspeção sem grupo).