Apache Kafka

Høyreklikk i treet ▸ Legg til ▸ Kafka-forespørsel.

Felles konfigurasjon

Felt	Rolle
URL	Listen over brokere, atskilt med komma: hote1:9092,hote2:9092 — hele strengen løses opp av Handlebars før den deles opp
Klient-ID	Den clientId som annonseres til brokerne
Emne	Emnet, uansett modus
Modus	produce, consume eller browse

Autentisering

Felt	Verdier
SASL-mekanisme	none, plain, scram-sha-256, scram-sha-512
SASL-bruker / SASL-passord	Passordet godtar en verdi av typen Hemmelighet
TLS	Kan slås på uavhengig — en broker med TLS og uten SASL fungerer med mekanismen none

Modusen produce

Nøkkel, verdi, postheadere og eventuelt partisjon. Uten en eksplisitt partisjon brukes standardpartisjoneringen i klientbiblioteket. Svaret returnerer metadataene til posten som ble skrevet: emne, partisjon og offset.

Modusen consume

Felt	Rolle
Gruppe	Konsumentens groupId
Start-offset	earliest, latest eller specific
Spesifikk offset	En streng — Kafka-offsets er 64-bits heltall
Partisjoner	Et filter på klientsiden: tildelingen av partisjoner gjøres fortsatt av gruppen

Modusen browse

Inspiserer en partisjon uten konsumentgruppe: Restorm henter ut et begrenset antall meldinger og kobler seg deretter fra. Partisjonen er påkrevd i denne modusen.

Det er det rette verktøyet når du vil se hva som ligger i et emne uten å opprette en gruppe eller flytte en offset.

I et scenario

• Kafka produce — en enkeltstående handling som returnerer metadataene til posten;
• Kafka consume — abonnerer via konsumentgruppen og sender ut én hendelse per melding;
• Lukk Kafka-tilkobling — stopper konsumeringen.

Se Tilkoblinger og strømmer.

Kodeeksempler

Fem mål: JavaScript (kafkajs, både for produsering og konsumering) og kcat (produsering, konsumering og inspeksjon uten gruppe).