Apache Kafka

Clic dreapta în arbore ▸ Adaugă ▸ Cerere Kafka.

Configurare comună

Câmp	Rol
URL	Lista brokerilor, separați prin virgule: hote1:9092,hote2:9092 — întregul șir este rezolvat prin Handlebars înainte de a fi împărțit
Identificator de client	clientId-ul anunțat brokerilor
Subiect	Subiectul, indiferent de mod
Mod	produce, consume sau browse

Autentificare

Câmp	Valori
Mecanism SASL	none, plain, scram-sha-256, scram-sha-512
Utilizator SASL / Parolă SASL	Parola acceptă o valoare de tip Secret
TLS	Se poate activa independent — un broker în TLS fără SASL funcționează cu mecanismul none

Modul produce

Cheie, valoare, antete de înregistrare și, opțional, partiție. Fără partiție explicită se aplică partiționatorul implicit al bibliotecii client. Răspunsul returnează metadatele înregistrării scrise: subiect, partiție, offset.

Modul consume

Câmp	Rol
Grup	groupId-ul consumatorului
Offset de pornire	earliest, latest sau specific
Offset specific	Un șir — offseturile Kafka sunt numere întregi pe 64 de biți
Partiții	Un filtru la nivel de client: repartizarea partițiilor rămâne făcută de grup

Modul browse

Inspectează o partiție fără grup de consumatori: Restorm extrage din ea un număr limitat de mesaje, apoi se deconectează. Partiția este obligatorie în acest mod.

Este unealta potrivită pentru a privi ce se află într-un subiect fără a crea un grup și fără a deplasa vreun offset.

Într-un scenariu

• Producție Kafka — acțiune unitară, returnează metadatele înregistrării;
• Consum Kafka — se abonează prin grupul de consumatori și emite un eveniment pentru fiecare mesaj;
• Închidere conexiune Kafka — oprește consumarea.

Vedeți Conexiuni și fluxuri.

Fragmente de cod

Cinci ținte: JavaScript (kafkajs, în producere și în consumare) și kcat (producere, consumare, inspecție fără grup).