Une intégration complète permettant aux agents AI de gérer les clusters, les sujets et les enregistrements Kafka via une interface sécurisée et automatisée.
Installer & Télécharger
1. ClawHub CLI
Le moyen le plus rapide d'installer une compétence directement depuis le registre.
npx clawhub@latest install confluent
2. Installation manuelle
Copiez le dossier de la compétence dans l'un de ces emplacements
~/.openclaw/skills/ <project>/skills/ Priorité : Espace de travail > Local > Intégré
3. Installation du prompt
Copiez ce prompt dans OpenClaw pour l'installer automatiquement.
Aide-moi à installer confluent via Clawhub. Si Clawhub n'est pas installé, installe-le d'abord (npm i -g clawhub).
Vous préférez télécharger ?
Obtenez les fichiers bruts de la compétence dans une archive ZIP.
Qu'est-ce que Confluent ?
L'intégration Confluent fournit une interface robuste permettant aux agents AI d'interagir avec la plateforme de streaming de données Confluent. En utilisant ces Openclaw Skills, les développeurs peuvent automatiser la gestion des clusters, des organisations et des environnements Kafka sans la complexité de la plomberie d'authentification manuelle. Cette compétence agit comme un pont entre les intentions des agents de haut niveau et les complexités techniques de l'infrastructure de données en temps réel.
Construite sur l'écosystème Membrane, la compétence gère le cycle de vie complet des identifiants, y compris le stockage sécurisé des jetons et les rafraîchissements transparents. Cela permet aux agents d'effectuer des opérations complexes telles que la configuration de sujets, la production d'enregistrements et la gestion des ACL de manière sûre et efficace. Que vous construisiez des outils de surveillance ou des pipelines de données automatisés, cette compétence garantit une expérience conviviale pour les développeurs avec un minimum de code répétitif.
Cas d'utilisation de Confluent
- Automatisation de la création et de la configuration des sujets Kafka lors du déploiement de l'application.
- Surveillance en temps réel et liste des clusters Kafka et des statuts des groupes de consommateurs.
- Ajustement dynamique du nombre de partitions de sujets en fonction de la charge du système ou des besoins de mise à l'échelle.
- Production programmatique d'enregistrements dans des sujets pour des tests ou des déclencheurs d'événements automatisés.
- Gestion des politiques de sécurité et des listes de contrôle d'accès (ACL) sur plusieurs environnements.
Comment fonctionne Confluent
- L'utilisateur installe le Membrane CLI et authentifie l'environnement de l'agent à l'aide d'une commande de connexion spécialisée.
- Une connexion à Confluent est établie via une vérification de domaine normalisée, qui gère le handshake initial OAuth ou API key.
- L'agent interroge l'état de la connexion, répondant à tous les déclencheurs CLIENT_ACTION_REQUIRED tels que l'authentification via navigateur.
- Une fois la connexion READY, l'agent recherche des actions spécifiques basées sur l'intention en langage naturel (ex : « Lister tous les clusters actifs »).
- L'agent exécute l'action choisie ou envoie une requête proxy directe à l'API Confluent, Membrane injectant automatiquement les en-têtes et les jetons requis.
Configuration de Confluent
Pour intégrer Confluent dans votre workflow Openclaw Skills, installez d'abord le CLI requis :
npm install -g @membranehq/cli@latest
Connectez-vous et spécifiez votre type d'agent :
membrane login --tenant --clientName=openclaw
Assurez-vous qu'une connexion est active pour le domaine Confluent :
membrane connection ensure "https://www.confluent.io/" --json
Si la connexion est en cours de création, utilisez le drapeau wait pour rester informé :
membrane connection get <id> --wait --json
Schéma de données et taxonomie de Confluent
La compétence organise les métadonnées Confluent dans une hiérarchie structurée pour une consommation facile par l'agent :
| Catégorie d'objet | Composants clés |
|---|---|
| Infrastructure | Clusters, Brokers, Partitions et Kafka Connectors. |
| Gouvernance | Organizations, Environments, Service Accounts et Users. |
| Données | Topics (Configs, Offsets) et Records individuels. |
| Sécurité | Access Control Lists (ACLs) et métadonnées d'état d'authentification. |
Toutes les réponses de l'API sont formatées en JSON lisible par machine pour prendre en charge l'analyse automatisée et le branchement logique dans les workflows des agents.
Fonctionnalités avancées de Confluent
- Correspondance d'intention en langage naturel pour découvrir la meilleure action pour une tâche spécifique.
- Requêtes proxy d'API directes qui gèrent automatiquement le mappage de l'URL de base et l'injection d'authentification.
- Prise en charge de l'authentification en environnement headless via la saisie manuelle de code.
- Pagination et gestion des erreurs intégrées pour les configurations de grands clusters Kafka.
- Prise en charge multi-entité permettant aux agents de basculer entre différents environnements Confluent de manière transparente.
SKILL.md
Chargement
Compétences Openclaw associées
LoyJoy
Une intégration spécialisée permettant aux AI Agents de gérer les flux de travail de marketing conversationnel LoyJoy et d'automatiser les interactions clients basées sur le chat.
SignWell
Une intégration complète de signature électronique pour Openclaw Skills qui permet une gestion transparente des documents et la signature de contrats directement via votre AI agent.
Contrôle Ring Doorbell & Caméra
Une intégration professionnelle pour surveiller et contrôler les sonnettes et caméras de sécurité Ring via une interface pilotée par AI.
NetEase Cloud Music Hot Trend
Un outil spécialisé pour analyser les tendances musicales publiques, la performance des playlists et les statistiques des artistes sur la plateforme NetEase Cloud Music.
Sendbird
Une intégration complète pour gérer les plateformes de messagerie Sendbird, incluant l'administration des utilisateurs et des canaux via une interface prête pour l'IA.
SignalWire
Une intégration puissante qui permet aux agents AI de gérer les appels vocaux, la messagerie et la communication vidéo via les APIs SignalWire.
En vedette*
