Apache Kafka

Klik me të djathtën në pemë ▸ Shto ▸ Kërkesë Kafka.

Një skedë Kafka në modalitetin Konsumim: lista e ndërmjetësve, tema, ID-ja e grupit, offset-i i nisjes «earliest» dhe filtri i ndarjeve

Konfigurimi i përbashkët

Fusha	Roli
URL	Lista e ndërmjetësve, të ndarë me presje: `hote1:9092,hote2:9092` — i gjithë vargu zgjidhet nga Handlebars përpara se të copëtohet
Identifikuesi i klientit	`clientId` që u shpallet ndërmjetësve
Tema	Tema, cilido qoftë modaliteti
Modaliteti	`produce`, `consume` ose `browse`

Vërtetimi

Fusha	Vlerat
Mekanizmi SASL	`none`, `plain`, `scram-sha-256`, `scram-sha-512`
Përdoruesi SASL / Fjalëkalimi SASL	Fjalëkalimi pranon një vlerë të tipit Sekret
TLS	I aktivizueshëm në mënyrë të pavarur — një ndërmjetës me TLS pa SASL funksionon me mekanizmin `none`

Modaliteti `produce`

Çelës, vlerë, koka regjistrimi dhe, sipas dëshirës, ndarje. Pa një ndarje të shprehur qartë, zbatohet ndarësi i parazgjedhur i bibliotekës kliente. Përgjigjja kthen metatë dhënat e regjistrimit të shkruar: temë, ndarje, offset.

Modaliteti `consume`

Fusha	Roli
Grupi	`groupId` i konsumatorit
Offset-i i nisjes	`earliest`, `latest` ose `specific`
Offset specifik	Një varg — offset-et e Kafkës janë numra të plotë 64-bitësh
Ndarjet	Një filtër nga ana e klientit: caktimi te ndarjet mbetet punë e grupit

Modaliteti `browse`

Inspekton një ndarje pa grup konsumatorësh: Restorm merr prej saj një numër të kufizuar mesazhesh dhe pastaj shkëputet. Ndarja është e detyrueshme në këtë modalitet.

Kjo është vegla e duhur për të parë çfarë ka brenda një teme pa krijuar grup dhe pa lëvizur asnjë offset.

Brenda një skenari

Prodhim Kafka — veprim njësh, kthen metatë dhënat e regjistrimit;
Konsumim Kafka — abonohet përmes grupit të konsumatorëve dhe lëshon një ngjarje për çdo mesazh;
Mbyllje e lidhjes Kafka — ndalon konsumimin.

Shihni Lidhjet dhe flukset.

Copëzat e kodit

Pesë caqe: JavaScript (kafkajs, në prodhim dhe në konsumim) dhe kcat (prodhim, konsumim, inspektim pa grup).