Apache Kafka
Desni klik u stablu ▸ Dodaj ▸ Kafka zahtev.
Zajednička konfiguracija
Section titled “Zajednička konfiguracija”| Polje | Uloga |
|---|---|
| URL | Lista brokera, razdvojenih zarezima: hote1:9092,hote2:9092 — cela niska se razrešava Handlebarsom pre deljenja |
| Identifikator klijenta | clientId koji se najavljuje brokerima |
| Tema | Tema, bez obzira na režim |
| Režim | produce, consume ili browse |
Autentifikacija
Section titled “Autentifikacija”| Polje | Vrednosti |
|---|---|
| SASL mehanizam | none, plain, scram-sha-256, scram-sha-512 |
| SASL korisnik / SASL lozinka | Lozinka prihvata vrednost tipa Tajna |
| TLS | Uključuje se nezavisno — broker sa TLS-om bez SASL-a radi sa mehanizmom none |
Režim produce
Section titled “Režim produce”Ključ, vrednost, zaglavlja zapisa i, opciono, particija. Bez izričite particije primenjuje se podrazumevani particioner klijentske biblioteke. Odgovor vraća metapodatke upisanog zapisa: tema, particija, ofset.
Režim consume
Section titled “Režim consume”| Polje | Uloga |
|---|---|
| Grupa | groupId potrošača |
| Početni ofset | earliest, latest ili specific |
| Određeni ofset | Niska — Kafka ofseti su 64-bitni celi brojevi |
| Particije | Filter na strani klijenta: dodelu particija i dalje obavlja grupa |
Režim browse
Section titled “Režim browse”Pregleda particiju bez grupe potrošača: Restorm iz nje uzima ograničen broj poruka pa se odjavljuje. Particija je obavezna u ovom režimu.
To je pravi alat da pogledate šta se nalazi u temi bez pravljenja grupe i bez pomeranja ofseta.
U scenariju
Section titled “U scenariju”- Kafka proizvodnja — pojedinačna akcija, vraća metapodatke zapisa;
- Kafka potrošnja — pretplaćuje se preko grupe potrošača i emituje po jedan događaj za svaku poruku;
- Zatvaranje Kafka veze — zaustavlja potrošnju.
Vidite Veze i tokovi.
Isečci koda
Section titled “Isečci koda”Pet odredišta: JavaScript (kafkajs, za proizvodnju i za potrošnju) i kcat
(proizvodnja, potrošnja, pregled bez grupe).