Apache Kafka

Rechtsklick im Baum ▸ Hinzufügen ▸ Kafka-Anfrage.

Gemeinsame Konfiguration

Feld	Rolle
URL	Die durch Kommas getrennte Broker-Liste: host1:9092,host2:9092 — die gesamte Zeichenkette wird vor dem Aufteilen von Handlebars aufgelöst
Client-ID	Die den Brokern gemeldete clientId
Topic	Das Topic, unabhängig vom Modus
Modus	produce, consume oder browse

Authentifizierung

Feld	Werte
SASL-Mechanismus	none, plain, scram-sha-256, scram-sha-512
SASL-Benutzer / SASL-Passwort	Das Passwort akzeptiert einen Wert vom Typ Secret
TLS	Unabhängig aktivierbar — ein Broker mit TLS ohne SASL funktioniert mit dem Mechanismus none

Modus produce

Schlüssel, Wert, Record-Header und optional Partition. Ohne explizite Partition greift der Standard-Partitionierer der Client-Bibliothek. Die Antwort liefert die Metadaten des geschriebenen Records: Topic, Partition, Offset.

Modus consume

Feld	Rolle
Gruppe	Die groupId des Consumers
Startoffset	earliest, latest oder specific
Spezifischer Offset	Eine Zeichenkette — Kafka-Offsets sind 64-Bit-Ganzzahlen
Partitionen	Ein clientseitiger Filter: Die Zuweisung der Partitionen bleibt bei der Gruppe

Modus browse

Inspiziert eine Partition ohne Consumer-Gruppe: Restorm entnimmt dabei eine begrenzte Anzahl Nachrichten und trennt dann die Verbindung. Die Partition ist in diesem Modus verpflichtend.

Das ist das richtige Werkzeug, um in ein Topic hineinzuschauen, ohne eine Gruppe anzulegen oder einen Offset zu verschieben.

In einem Szenario

• Kafka-Produktion — einmalige Aktion, liefert die Metadaten des Records zurück;
• Kafka-Konsum — abonniert über die Consumer-Gruppe und löst pro Nachricht ein Ereignis aus;
• Kafka-Verbindung schließen — stoppt den Konsum.

Siehe Verbindungen und Streams.

Code-Snippets

Fünf Ziele: JavaScript (kafkajs, für Produktion und Konsum) und kcat (Produktion, Konsum, Inspektion ohne Gruppe).