Apache Kafka

Klikněte pravým tlačítkem ve stromu ▸ Přidat ▸ Požadavek Kafka.

Karta Kafka v režimu Konzumovat: seznam brokerů, téma, ID skupiny, počáteční offset „earliest“ a filtr oddílů

Společná konfigurace

Pole	Role
URL	Seznam brokerů oddělených čárkami: `hote1:9092,hote2:9092` — celý řetězec se vyhodnotí přes Handlebars před rozdělením
ID klienta	`clientId` ohlašovaný brokerům
Téma	Téma, bez ohledu na režim
Režim	`produce`, `consume` nebo `browse`

Ověřování

Pole	Hodnoty
Mechanismus SASL	`none`, `plain`, `scram-sha-256`, `scram-sha-512`
Uživatel SASL / Heslo SASL	Heslo přijímá hodnotu typu Tajný klíč
TLS	Zapínatelné nezávisle — broker s TLS bez SASL funguje s mechanismem `none`

Režim `produce`

Klíč, hodnota, hlavičky záznamu a volitelně oddíl. Bez výslovného oddílu se použije výchozí rozdělovač klientské knihovny. Odpověď vrací metadata zapsaného záznamu: téma, oddíl, offset.

Režim `consume`

Pole	Role
Skupina	`groupId` konzumenta
Počáteční offset	`earliest`, `latest` nebo `specific`
Konkrétní offset	Řetězec — offsety Kafka jsou 64bitová celá čísla
Oddíly	Filtr na straně klienta: přiřazení oddílů zůstává na skupině

Režim `browse`

Nahlédne do oddílu bez skupiny konzumentů: Restorm z něj odebere omezený počet zpráv a potom se odpojí. Oddíl je v tomto režimu povinný.

To je ten správný nástroj, chcete-li se podívat, co je v tématu, bez zakládání skupiny a bez posouvání offsetu.

Ve scénáři

Produkce Kafka — jednorázová akce, vrací metadata záznamu;
Konzumace Kafka — přihlásí se k odběru přes skupinu konzumentů a vysílá jednu událost na každou zprávu;
Zavřít připojení Kafka — zastaví konzumaci.

Viz Připojení a streamy.

Ukázky kódu

Pět cílů: JavaScript (kafkajs, pro produkci i konzumaci) a kcat (produkce, konzumace, inspekce bez skupiny).