AI Agent Skills by Confluent — плагин
Скиллы Confluent для потоковых приложений: клиенты Kafka, Schema Registry, Flink SQL, CDC и миграция с MSK.
- 64 ★ репозитория
- Последний коммит
- Apache-2.0
Расширенный доступ
Почему такой уровень
- Скиллы пишут код и Terraform и обращаются к Confluent Cloud с вашими учетными данными.
Установка
- Работает в
В терминале, через SkillFoxx CLI
npx skillfoxx add plugins/ai-agent-skills-by-confluentОпределит агенты на машине, покажет уровень доступа и зафиксирует версию.
Другие способы установки
Доступ и проверки
Как мы проверяемРасширенный доступИнструмент запускает код или ходит в сеть, а внешние данные только читает.
- Скиллы пишут код и Terraform и обращаются к Confluent Cloud с вашими учетными данными.
Это чужой код. Посмотрите файлы в репозитории перед установкой.
Что делает
Набор Confluent помогает агенту строить приложения и конвейеры потоковых данных. В нем скиллы для клиентов Kafka на Java и Python со Schema Registry и сериализацией Avro, JSON Schema или Protobuf, для Kafka Streams, пользовательских функций Flink и Flink SQL на Confluent Cloud с разбором 22 расхождений диалектов. Отдельные скиллы настраивают конвейеры CDC на Confluent Cloud с коннекторами Debezium, Flink и Tableflow, ищут в проекте Kafka-приложения для регистрации схем с метками PII и готовым Terraform, оценивают переезд с AWS MSK на Confluent Cloud и готовят интеграцию облачного провайдера. Скилл `confluent-tuning-advisor` смотрит настройки топиков, клиентов и брокеров только на чтение.
Для кого. Разработчикам и инженерам данных, которые строят приложения на Kafka и Flink с Confluent Cloud и поручают рутину агенту.
Подходит, если
- Нужен продюсер Kafka на Python, отправляющий события профиля в Confluent Cloud.
- Приложение на Flink Table API на Python фильтрует поток.
- В репозитории ищут схемы Kafka, помечают PII и готовят Terraform для Schema Registry.
- Планируют переезд с AWS MSK на Confluent Cloud с выбором между Cluster Linking и Gateway.
Не подходит, если
- Работаете с другой платформой потоков вместо Confluent.
- Нужно выполнять миграцию автоматически, без чтения и проверки результата.
- Среде не разрешено создавать Terraform и обращаться к Confluent CLI.
Пример запроса к агенту
Создай продюсер Kafka на Python, который отправляет события обновления профиля в Confluent Cloud со Schema Registry.Ограничения
Результат зависит от модели, она недетерминирована, поэтому код и изменения от скиллов нужно проверять и тестировать, особенно для боевых систем. Для Confluent Cloud требуются ваш аккаунт и учетные данные, часть скиллов использует Confluent CLI, MCP-сервер Confluent или REST API. Скилл миграции с MSK планирует и направляет к документации и команде аккаунта для самого переезда. В IBM Bob скилл копируют в `~/.bob/skills` вручную, иначе он не загрузится при запуске.
Как отключить. Удалите плагин командой Claude Code или папки скиллов, поставленные `npx skills`, и очистите локальные файлы с учетными данными `.env` или YAML.
Частые вопросы
Как поставить набор?
В Claude Code выполните `/plugin marketplace add confluentinc/agent-skills` и `/plugin install streaming-skills-plugin@confluent-agent-skills`.
Как выбрать отдельные скиллы?
Командой `npx skills add confluentinc/agent-skills`: она дает выбрать скиллы и поддерживает большинство агентов.
Какие скиллы есть для Flink?
`flink-udf` для функций на Java, `confluent-cloud-flink-sql` для SQL на Confluent Cloud и `confluent-cloud-cdc-tableflow` для конвейеров CDC.
Что делает kafka-schema-registry?
Находит Kafka-приложения в проекте, достает схемы из моделей данных, помечает поля PII, готовит Terraform для регистрации и отчет о миграции.
Как ставить в IBM Bob?
Скопируйте нужный скилл в `~/.bob/skills`, иначе он не загрузится при запуске.
Обсуждение
Вопросов и отзывов пока нет.
Похожие
ПлагиныMCP-сервер Confluent для Kafka: топики, сообщения, Flink SQL, Schema Registry и коннекторы
Официальные скиллы Databricks направляют агента при работе с данными, заданиями Lakeflow и развертыванием ресурсов платформы.
Официальные скиллы Elastic для Elasticsearch, Kibana, Observability, Security и Elastic Cloud: ES|QL, индексы, дашборды, триаж алертов
Скиллы для Neo4j: запросы Cypher, моделирование графов, драйверы, импорт, GraphRAG, GDS и создание экземпляров Aura
Набор Databricks Field Engineering для агентов: установщик скиллов Databricks, MCP-сервер и визуальный Builder App
43 скилла для медицины и наук о жизни: геномика, клинические данные, разработка лекарств, CDISC и расчеты по страховым выплатам
Коротко о README
Репозиторий собирает скиллы Confluent для разработки приложений потоковой передачи данных. Каждый скилл следует лучшим практикам Schema Registry, безопасности и обработки ошибок.