Apache Kafka

Jobb kattintás a projektfában ▸ Hozzáadás ▸ Kafka-kérés.

Kafka-lap Fogyasztás módban: a brókerlista, a téma, a csoportazonosító, az „earliest” kezdő offset és a partíciószűrő

Közös konfiguráció

Mező	Szerepe
URL	A brókerek vesszővel elválasztott listája: `hote1:9092,hote2:9092` — a teljes karakterláncot a Handlebars oldja fel, mielőtt felbontásra kerülne
Kliensazonosító	A brókereknek bejelentett `clientId`
Téma	A téma (topic), módtól függetlenül
Mód	`produce`, `consume` vagy `browse`

Hitelesítés

Mező	Értékek
SASL-mechanizmus	`none`, `plain`, `scram-sha-256`, `scram-sha-512`
SASL-felhasználó / SASL-jelszó	A jelszó elfogad Titok típusú értéket
TLS	Egymástól függetlenül bekapcsolható — a SASL nélküli, TLS-t használó bróker a `none` mechanizmussal működik

`produce` mód

Kulcs, érték, rekordfejlécek és — nem kötelezően — partíció. Explicit partíció nélkül a kliens könyvtár alapértelmezett partícionálója érvényesül. A válasz a megírt rekord metaadatait adja vissza: téma, partíció, offset.

`consume` mód

Mező	Szerepe
Csoport	A fogyasztó `groupId` értéke
Kezdő offset	`earliest`, `latest` vagy `specific`
Meghatározott offset	Karakterlánc — a Kafka offsetjei 64 bites egészek
Partíciók	Ügyféloldali szűrő: a partíciók hozzárendelését továbbra is a csoport végzi

`browse` mód

Egy partíciót fogyasztói csoport nélkül vizsgál meg: a Restorm korlátozott számú üzenetet vesz ki belőle, majd lekapcsolódik. Ebben a módban a partíció megadása kötelező.

Ez a megfelelő eszköz arra, hogy egy téma tartalma csoport létrehozása és offset elmozdítása nélkül megtekinthető legyen.

Forgatókönyvben

Kafka-előállítás — egyszeri művelet, a rekord metaadatait adja vissza;
Kafka-fogyasztás — a fogyasztói csoporton keresztül iratkozik fel, és üzenetenként eseményt bocsát ki;
Kafka-kapcsolat bezárása — leállítja a fogyasztást.

Lásd: Kapcsolatok és folyamok.

Kódrészletek

Öt cél: JavaScript (kafkajs, előállításhoz és fogyasztáshoz) és kcat (előállítás, fogyasztás, csoport nélküli vizsgálat).