Apache Kafka

Rechtsklik in de boom ▸ Toevoegen ▸ Kafka-verzoek.

Gemeenschappelijke configuratie

Veld	Rol
URL	De lijst met brokers, door komma’s gescheiden: hote1:9092,hote2:9092 — de hele tekenreeks wordt door Handlebars opgelost voordat hij wordt opgesplitst
Client-ID	De clientId die aan de brokers wordt gemeld
Topic	Het topic, in elke modus
Modus	produce, consume of browse

Authenticatie

Veld	Waarden
SASL-mechanisme	none, plain, scram-sha-256, scram-sha-512
SASL-gebruiker / SASL-wachtwoord	Het wachtwoord accepteert een waarde van het type Geheim
TLS	Onafhankelijk in te schakelen — een broker met TLS zonder SASL werkt met het mechanisme none

Modus produce

Sleutel, waarde, recordheaders en eventueel een partitie. Zonder expliciete partitie geldt de standaardpartitioner van de clientbibliotheek. De respons geeft de metadata van het geschreven record terug: topic, partitie, offset.

Modus consume

Veld	Rol
Groep	De groupId van de consumer
Startoffset	earliest, latest of specific
Specifieke offset	Een tekenreeks — Kafka-offsets zijn 64-bits gehele getallen
Partities	Een filter aan de clientzijde: de toewijzing aan partities blijft bij de groep

Modus browse

Inspecteert een partitie zonder consumergroep: Restorm haalt er een begrensd aantal berichten uit en verbreekt daarna de verbinding. De partitie is in deze modus verplicht.

Dat is het juiste middel om te zien wat er in een topic zit, zonder een groep aan te maken of een offset te verschuiven.

In een scenario

• Kafka produce — een enkelvoudige actie, geeft de metadata van het record terug;
• Kafka consume — abonneert zich via de consumergroep en stuurt per bericht een event uit;
• Kafka-verbinding sluiten — stopt het consumeren.

Zie Verbindingen en streams.

Codefragmenten

Vijf doelen: JavaScript (kafkajs, voor produceren en consumeren) en kcat (produceren, consumeren, inspecteren zonder groep).