Apache Kafka
Högerklicka i trädet ▸ Lägg till ▸ Kafka-begäran.
Gemensam konfiguration
Section titled “Gemensam konfiguration”| Fält | Roll |
|---|---|
| URL | Listan över brokrar, separerade med kommatecken: hote1:9092,hote2:9092 — hela strängen löses upp av Handlebars innan den delas upp |
| Klient-ID | Det clientId som annonseras till brokrarna |
| Ämne | Ämnet, oavsett läge |
| Läge | produce, consume eller browse |
Autentisering
Section titled “Autentisering”| Fält | Värden |
|---|---|
| SASL-mekanism | none, plain, scram-sha-256, scram-sha-512 |
| SASL-användare / SASL-lösenord | Lösenordet tar emot ett värde av typen Hemlighet |
| TLS | Kan slås på oberoende — en broker med TLS men utan SASL fungerar med mekanismen none |
Läget produce
Section titled “Läget produce”Nyckel, värde, postheaders och, valfritt, partition. Utan uttalad partition gäller klientbibliotekets standardpartitionerare. Svaret returnerar metadata för den skrivna posten: ämne, partition, offset.
Läget consume
Section titled “Läget consume”| Fält | Roll |
|---|---|
| Grupp | Konsumentens groupId |
| Startoffset | earliest, latest eller specific |
| Specifik offset | En sträng — Kafka-offsets är 64-bitars heltal |
| Partitioner | Ett filter på klientsidan: tilldelningen av partitioner görs fortfarande av gruppen |
Läget browse
Section titled “Läget browse”Inspekterar en partition utan konsumentgrupp: Restorm plockar ut ett begränsat antal meddelanden och kopplar sedan ner. Partitionen är obligatorisk i det här läget.
Det är det rätta verktyget för att se vad som ligger i ett ämne utan att skapa en grupp eller flytta någon offset.
I ett scenario
Section titled “I ett scenario”- Kafka produce — enskild åtgärd, returnerar postens metadata;
- Kafka consume — prenumererar via konsumentgruppen och utlöser en händelse per meddelande;
- Stäng Kafka-anslutning — stoppar konsumtionen.
Kodavsnitt
Section titled “Kodavsnitt”Fem mål: JavaScript (kafkajs, för produktion och konsumtion) och kcat
(produktion, konsumtion, inspektion utan grupp).