Apache-Kafka-Client für Mac

Gib Host und Port eines Brokers ein; darüber wird der restliche Cluster entdeckt. Zusätzliche Bootstrap-Server listet Broker, die versucht werden, wenn der erste nicht antwortet. Eine Verbindung entspricht einem Cluster; es gibt daher kein Datenbankfeld, und die Seitenleiste zeigt seine Topics direkt.

Sicherheitsprotokoll ist PLAINTEXT, SSL, SASL_PLAINTEXT oder SASL_SSL; SASL-Mechanismus ist PLAIN, SCRAM-SHA-256 oder SCRAM-SHA-512. PLAIN eignet sich für Confluent Cloud, SCRAM für Amazon MSK und selbst betriebene Broker. Bei SSL oder SASL_SSL ohne gewählten SSL-Modus werden Zertifikatskette und Hostname geprüft. Eine private CA kommt in CA-Zertifikat; Client-Zertifikat und Schlüssel ergänzen gegenseitiges TLS.

Über einen SSH-Tunnel bleibt die Verbindung beim Bootstrap-Broker und liest daher nur die Partitionen, deren Leader er ist. Aus URL importieren… akzeptiert kafka://-URLs, die macOS nicht als Links öffnet.

Beim Öffnen eines Topics erscheinen die neuesten Nachrichten, die neueste zuletzt, mit Partition, Offset, Zeitstempel, Schlüssel, Wert, Headern und Größen. Nachrichten aus verschiedenen Partitionen werden als Lesehilfe nach Zeitstempel ineinander angeordnet; Partition und Offset identifizieren die Nachricht. Ein Schlüssel oder Wert ohne UTF-8 erscheint als Hex; ein Tombstone bleibt von einer leeren Nachricht unterscheidbar.

KafkaQL ersetzt Sortieren und Filtern durch eine Startposition: CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET oder FROM TIME mit ISO-8601-Zeitstempel, optional auf bestimmte Partitionen begrenzt. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER und DESCRIBE TOPIC decken den restlichen Cluster ab.

DESCRIBE GROUP zeigt den Lag-Bericht: bestätigter Offset, End-Offset und Abstand pro Partition. Eine Partition, für die die Gruppe nie bestätigt hat, zeigt keinen Lag statt eines ab null gezählten Werts. SHOW GROUPS markiert die Liste als gekürzt, wenn ein Broker nicht erreichbar ist.

PRODUCE INTO schreibt eine Nachricht mit optionalem Schlüssel, Headern und Partition. Eine Nachricht mit Schlüssel ohne Partition landet dort, wo Kafkas eigener Producer sie ablegen würde. gzip-, snappy-, lz4- und zstd-Batches werden beim Lesen ohne wählbare Einstellung dekomprimiert.

Zellen lassen sich nicht bearbeiten, Zeilen nicht löschen und Spalten nicht sortieren, da Kafka keine Updates, kein Löschen einzelner Nachrichten und keine serverseitige Sortierung bietet; das Raster blendet diese Bedienelemente ab. Jede Seite setzt am Ende der vorherigen fort, sodass ein beschriebenes Topic keine Nachricht wiederholt oder überspringt.

Das Löschen eines Topics aus der Seitenleiste oder mit DROP TOPIC ist die einzige destruktive Aktion. Der Cluster entfernt das Log danach; das Topic kann daher kurz in der Liste bleiben. Leeren wird nicht angeboten: Kafka entfernt Datensätze über Aufbewahrung oder einen Offset pro Partition, und beides leert kein Topic.

Es gibt keinen Import; schreibe Nachrichten mit PRODUCE INTO in ein Topic. Exportiere die von einer Abfrage gelesenen Nachrichten als CSV, JSON oder XLSX.

Die App für iPhone und iPad hat keinen Apache Kafka-Treiber. Vom Mac synchronisierte Apache Kafka-Verbindungen erscheinen in ihrer Liste, lassen sich aber nicht öffnen.