Aller au contenu

Une licence ajoute les fonctions payantes et finance la prochaine version de TablePro. Acheter une licenceUne licence pour aider TablePro

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

Instruction KafkaQL CONSUME sur un topic orders, avec messages listés par partition, offset, clé et horodatage.

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

L’app Mac se télécharge et s’utilise gratuitement. Un forfait Starter ou Équipe ajoute des fonctions facultatives.
Télécharger pour Mac

Nécessite macOS 13 Ventura ou version ultérieure