Apache Kafka
Desni klik u stablu ▸ Dodaj ▸ Kafka zahtjev.

Zajednička konfiguracija
Section titled “Zajednička konfiguracija”| Polje | Uloga |
|---|---|
| URL | Popis posrednika, odvojenih zarezima: hote1:9092,hote2:9092 — cijeli niz Handlebars razrješava prije rezanja |
| Identifikator klijenta | clientId koji se objavljuje posrednicima |
| Tema | Tema, bez obzira na način |
| Način | produce, consume ili browse |
Autentifikacija
Section titled “Autentifikacija”| Polje | Vrijednosti |
|---|---|
| SASL mehanizam | none, plain, scram-sha-256, scram-sha-512 |
| SASL korisnik / SASL lozinka | Lozinka prihvaća vrijednost tipa Tajna |
| TLS | Uključuje se neovisno — posrednik na TLS-u bez SASL-a radi s mehanizmom none |
Način produce
Section titled “Način produce”Ključ, vrijednost, zaglavlja zapisa i, po izboru, particija. Bez izričite particije primjenjuje se zadani razdjelnik klijentske biblioteke. Odgovor vraća metapodatke zapisanog zapisa: temu, particiju, offset.
Način consume
Section titled “Način consume”| Polje | Uloga |
|---|---|
| Grupa | groupId potrošača |
| Početni offset | earliest, latest ili specific |
| Određeni offset | Niz — Kafka offseti 64-bitni su cijeli brojevi |
| Particije | Filtar na strani klijenta: dodjelu particija i dalje obavlja grupa |
Način browse
Section titled “Način browse”Pregledava particiju bez potrošačke grupe: Restorm iz nje uzima ograničen broj poruka pa se odspaja. Particija je obavezna u ovom načinu.
To je pravi alat za pogled na sadržaj teme bez stvaranja grupe i pomicanja offseta.
U scenariju
Section titled “U scenariju”- Kafka proizvodnja — pojedinačna akcija, vraća metapodatke zapisa;
- Kafka potrošnja — pretplaćuje se preko potrošačke grupe i emitira po jedan događaj za svaku poruku;
- Zatvaranje Kafka veze — zaustavlja potrošnju.
Pogledajte Veze i tokove.
Isječci koda
Section titled “Isječci koda”Pet odredišta: JavaScript (kafkajs, u proizvodnji i potrošnji) i kcat
(proizvodnja, potrošnja, pregled bez grupe).