Apache Kafka

Højreklik i træstrukturen ▸ Tilføj ▸ Kafka-anmodning.

En Kafka-fane i tilstanden Forbrug: brokerlisten, emnet, gruppe-id'et, startoffsettet »earliest« og partitionsfilteret

Fælles konfiguration

Felt	Rolle
URL	Listen over brokere, adskilt af kommaer: `hote1:9092,hote2:9092` — hele strengen bliver løst af Handlebars, før den bliver delt op
Klient-id	Det `clientId`, der bliver annonceret til brokerne
Emne	Emnet, uanset tilstand
Tilstand	`produce`, `consume` eller `browse`

Godkendelse

Felt	Værdier
SASL-mekanisme	`none`, `plain`, `scram-sha-256`, `scram-sha-512`
SASL-bruger / SASL-adgangskode	Adgangskoden accepterer en værdi af typen Hemmelighed
TLS	Kan slås til uafhængigt — en broker med TLS uden SASL virker med mekanismen `none`

Tilstanden `produce`

Nøgle, værdi, record-headere og eventuelt partition. Uden en eksplicit partition gælder klientbibliotekets standardpartitioner. Svaret sender metadataene for den skrevne record tilbage: emne, partition, offset.

Tilstanden `consume`

Felt	Rolle
Gruppe	Forbrugerens `groupId`
Startoffset	`earliest`, `latest` eller `specific`
Specifikt offset	En streng — Kafka-offsets er 64-bit-heltal
Partitioner	Et filter på klientsiden: tildelingen af partitioner bliver stadig foretaget af gruppen

Tilstanden `browse`

Inspicerer en partition uden en forbrugergruppe: Restorm tager et begrænset antal beskeder ud af den og afbryder så forbindelsen. Partitionen er obligatorisk i denne tilstand.

Det er det rigtige værktøj til at se, hvad der ligger i et emne, uden at oprette en gruppe eller flytte et offset.

I et scenarie

Kafka produce — en enkeltstående handling, sender recordens metadata tilbage;
Kafka consume — abonnerer via forbrugergruppen og udsender en hændelse per besked;
Luk Kafka-forbindelse — stopper forbruget.

Se Streaming-forbindelser.

Kodestykker

Fem mål: JavaScript (kafkajs, til produktion og forbrug) og kcat (produktion, forbrug, inspektion uden gruppe).