kafka-stream-processing — скилл для Claude Code: установка и суть
Скилл снабжает ИИ-агента инструкциями по проектированию потоковой обработки на Apache Kafka. Он пригодится при настройке продюсеров, консьюмеров и топологий Kafka Streams.
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a claude-codeЧто делает kafka-stream-processing
Скилл обучает ассистента строить событийные сервисы и конвейеры обработки потоков. В центре внимания находятся структура топиков и распределение тасок внутри приложений Kafka Streams. Агент получает чёткие правила по выбору гарантий доставки: от семантики at-least-once до транзакционного режима exactly-once.
Практическая часть охватывает администрирование через штатную утилиту kafka-topics.sh, а также масштабирование потоковых топологий. Параллелизм ограничен числом входных партиций. Дополнительные экземпляры приложения будут просто простаивать, ожидая сбоя активных узлов.
Увеличить число партиций на работающем топике можно через флаг --alter, но уменьшить их количество Kafka не позволяет. К тому же изменение состава партиций не перераспределит уже сохранённые записи и способно нарушить логику консьюмеров со специальным партиционированием.
Какие задачи решает
- сконфигурировать топики и партиции через CLI-скрипт
kafka-topics.sh - выстроить параллельную обработку сообщений в тасках Kafka Streams
- выбрать семантику доставки между at-least-once и exactly-once
- связать микросервисы в событийно-ориентированную цепочку
Примеры запросов агенту
- Помоги создать топик с двадцатью партициями и фактором репликации 3 через
kafka-topics.sh. - Как настроить приложение на Kafka Streams, если во входном топике пять партиций?
- Спроектируй обработку финансовых событий с семантикой exactly-once.
Как установить kafka-stream-processing
1Через Skills CLI (Vercel)
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a claude-code2Вручную: положить файлы
~/.claude/skills/kafka-stream-processing/SKILL.mdПапка скилла целиком; для одного проекта — .claude/skills/kafka-stream-processing/
1Через Skills CLI (Vercel)
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a codex2Вручную: положить файлы
.agents/skills/kafka-stream-processing/SKILL.mdДля всех проектов — ~/.agents/skills/
1Через Skills CLI (Vercel)
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a cursor2Вручную: положить файлы
.cursor/skills/kafka-stream-processing/SKILL.mdCursor читает и .agents/skills/, и .claude/skills/
1GitHub CLI
gh skill install manutej/luxor-claude-marketplace kafka-stream-processing2Вручную: положить файлы
.github/skills/kafka-stream-processing/SKILL.md1Через Skills CLI (Vercel)
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a gemini-cli2Командой платформы
gemini skills install https://github.com/manutej/luxor-claude-marketplace --path plugins/luxor-data-engineering/skills/kafka-stream-processingВручную: положить файлы
.devin/skills/kafka-stream-processing/SKILL.mdСтарый путь .windsurf/skills/ тоже читается
Через Skills CLI (Vercel)
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a opencodeClaude.ai
Упакуйте папку в zip и загрузите в Settings → Capabilities → Skills
По шагам, с командами для каждой платформы: Как установить скилл в Claude Code: пять способов
Вопросы о kafka-stream-processing
Как установить kafka-stream-processing в Claude Code?
Выполните команду npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a claude-code. Файл скилла будет добавлен по пути ~/.claude/skills/kafka-stream-processing/SKILL.md.
Что делает скилл kafka-stream-processing?
Он помогает проектировать распределённые потоки данных на базе Apache Kafka. Скилл подсказывает архитектуру продюсеров, схемы шардирования партиций и структуру тасок Kafka Streams.
Можно ли уменьшить количество партиций у топика Kafka?
Нет, утилита kafka-topics.sh позволяет только увеличивать число партиций через флаг --alter. Уменьшить их невозможно, а новое разделение не балансирует ранее записанные сообщения.
