Client Apache Kafka pour Mac
Lisez un topic depuis la position choisie, voyez le retard de chaque groupe de consommateurs et produisez un message de test avec KafkaQL. Un topic est un journal : la grille lit les messages sans jamais les modifier.
Fonctionne sur MacLe pilote se télécharge la première fois que vous choisissez Apache Kafka


En bref
- Langage de requête
- KafkaQL
- Pilote
- Téléchargé à la première utilisation
- Connexion via
- Hôte et port, Tunnel SSH, SSL/TLS
- Port par défaut
- 9092
- Version minimale
- 0.11, documentée
- iPhone et iPad
- Ne s’ouvre pas
Connexion
Saisissez l’hôte et le port d’un broker ; le reste du cluster est découvert à partir de lui. Serveurs bootstrap supplémentaires liste les brokers à essayer si le premier ne répond pas. Une connexion correspond à un cluster ; il n’y a donc pas de champ Base de données et la barre latérale affiche directement ses topics.
Le Protocole de sécurité est PLAINTEXT, SSL, SASL_PLAINTEXT ou SASL_SSL ; le Mécanisme SASL est PLAIN, SCRAM-SHA-256 ou SCRAM-SHA-512. PLAIN convient à Confluent Cloud, SCRAM à Amazon MSK et aux brokers autohébergés. Avec SSL ou SASL_SSL sans mode SSL choisi, la chaîne de certificats et le nom d’hôte sont vérifiés. Une AC privée va dans Certificat d’AC ; certificat client et clé ajoutent TLS mutuel.
Avec un tunnel SSH, la connexion reste sur le broker bootstrap et ne lit donc que les partitions dont il est leader. Importer depuis une URL… accepte les URL kafka://, que macOS n’ouvre pas comme liens.
Lisez, inspectez et produisez
Ouvrir un topic affiche ses messages récents, le plus récent en dernier, avec partition, offset, horodatage, clé, valeur, en-têtes et tailles. Les messages de partitions différentes sont entrelacés par date pour faciliter la lecture ; partition et offset identifient le message. Une clé ou valeur non UTF-8 s’affiche en hexadécimal et un tombstone reste distinct d’un message vide.
KafkaQL remplace tri et filtrage par une position initiale : CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET ou FROM TIME avec un horodatage ISO 8601, éventuellement limité à certaines partitions. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER et DESCRIBE TOPIC couvrent le reste du cluster.
DESCRIBE GROUP donne le rapport de retard : offset validé, offset final et écart par partition. Une partition où le groupe n’a jamais validé d’offset n’affiche pas de retard plutôt qu’un nombre compté depuis zéro ; SHOW GROUPS marque sa liste comme tronquée si un broker est inaccessible.
PRODUCE INTO écrit un message avec clé, en-têtes et partition facultatifs. Un message avec clé sans partition arrive là où le producteur Kafka le placerait. Les lots gzip, snappy, lz4 et zstd sont décompressés à la lecture, sans réglage à choisir.
Les cellules ne se modifient pas, les lignes ne se suppriment pas et les colonnes ne se trient pas, car Kafka n’a ni mise à jour, ni suppression par message, ni tri côté serveur ; la grille grise ces commandes. Chaque page reprend où la précédente s’arrête, donc un topic recevant des messages n’en répète ni n’en saute aucun.
Topics
Supprimer un topic depuis la barre latérale ou avec DROP TOPIC est la seule action destructive. Le cluster retire ensuite le journal ; le topic peut donc rester un moment dans la liste. Vider n’est pas proposé : Kafka retire les enregistrements par rétention ou offset par partition, sans vider un topic.
Transférez des données
Il n’y a pas d’import ; placez les messages dans un topic avec PRODUCE INTO. Exportez les messages lus par une requête en CSV, JSON ou XLSX.
iPhone et iPad
L’app iPhone et iPad n’a pas de pilote Apache Kafka. Les connexions Apache Kafka synchronisées depuis un Mac apparaissent dans sa liste, mais ne s’ouvrent pas.
Limites
- Schema Registry n’est pas lu ; les valeurs Avro et Protobuf apparaissent donc en octets bruts.
- La création de topics, leur configuration et la réinitialisation des offsets des groupes de consommateurs ne sont pas prises en charge.
- Les nombres de messages sont approximatifs.
Questions sur Apache Kafka
Pourquoi les topics chargent-ils mais les messages expirent ?
Le cluster annonce des adresses inaccessibles depuis ce Mac, comme un nom de conteneur ou une IP privée. Corrigez advertised.listeners ou définissez Adresses des brokers pour n’utiliser que l’adresse bootstrap.
L’authentification IAM d’Amazon MSK fonctionne-t-elle ?
Non. Les mécanismes SASL proposés sont PLAIN, SCRAM-SHA-256 et SCRAM-SHA-512 ; créez donc un utilisateur SCRAM dans le cluster MSK et connectez-vous avec SASL_SSL.
Obtenir TablePro
Nécessite macOS 13 Ventura ou version ultérieure