# kafka-stream-processing

Скилл снабжает ИИ-агента инструкциями по проектированию потоковой обработки на Apache Kafka. Он пригодится при настройке продюсеров, консьюмеров и топологий Kafka Streams.

- скилл · `type=skill` · Claude Code, Codex, Cursor, GitHub Copilot, Gemini CLI, OpenCode · 480 установок · ★ 62
- Автор: manutej
- Лицензия: не указана · policy=link-only · показываем только описание, файл — у автора
- Исходник: https://github.com/manutej/luxor-claude-marketplace/tree/HEAD/plugins/luxor-data-engineering/skills/kafka-stream-processing/SKILL.md
- Обновлён: 2026-06-13
- HTML: https://affpapa.org/nevibecode/skills/kafka-stream-processing

## Что делает

Скилл обучает ассистента строить событийные сервисы и конвейеры обработки потоков. В центре внимания находятся структура топиков и распределение тасок внутри приложений Kafka Streams. Агент получает чёткие правила по выбору гарантий доставки: от семантики at-least-once до транзакционного режима exactly-once.

Практическая часть охватывает администрирование через штатную утилиту `kafka-topics.sh`, а также масштабирование потоковых топологий. Параллелизм ограничен числом входных партиций. Дополнительные экземпляры приложения будут просто простаивать, ожидая сбоя активных узлов.

Увеличить число партиций на работающем топике можно через флаг `--alter`, но уменьшить их количество Kafka не позволяет. К тому же изменение состава партиций не перераспределит уже сохранённые записи и способно нарушить логику консьюмеров со специальным партиционированием.

## Установка

### Claude Code (родная платформа)

1. **Через Skills CLI (Vercel)**
```bash
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a claude-code
```

2. **Вручную: положить файлы**
- Файл: `~/.claude/skills/kafka-stream-processing/SKILL.md` — Папка скилла целиком; для одного проекта — .claude/skills/kafka-stream-processing/

### Codex

1. **Через Skills CLI (Vercel)**
```bash
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a codex
```

2. **Вручную: положить файлы**
- Файл: `.agents/skills/kafka-stream-processing/SKILL.md` — Для всех проектов — ~/.agents/skills/

### Cursor

1. **Через Skills CLI (Vercel)**
```bash
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a cursor
```

2. **Вручную: положить файлы**
- Файл: `.cursor/skills/kafka-stream-processing/SKILL.md` — Cursor читает и .agents/skills/, и .claude/skills/

### GitHub Copilot

1. **GitHub CLI**
```bash
gh skill install manutej/luxor-claude-marketplace kafka-stream-processing
```

2. **Вручную: положить файлы**
- Файл: `.github/skills/kafka-stream-processing/SKILL.md`

### Gemini CLI

1. **Через Skills CLI (Vercel)**
```bash
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a gemini-cli
```

2. **Командой платформы**
```bash
gemini skills install https://github.com/manutej/luxor-claude-marketplace --path plugins/luxor-data-engineering/skills/kafka-stream-processing
```

### Windsurf (Devin Desktop)

**Вручную: положить файлы**
- Файл: `.devin/skills/kafka-stream-processing/SKILL.md` — Старый путь .windsurf/skills/ тоже читается

### OpenCode

**Через Skills CLI (Vercel)**
```bash
npx skills add manutej/luxor-claude-marketplace --skill kafka-stream-processing -a opencode
```

### Claude.ai

**Claude.ai**
- Упакуйте папку в zip и загрузите в Settings → Capabilities → Skills

Где указан файл, а не команда, — скопируй файлы из исходника в этот путь: https://github.com/manutej/luxor-claude-marketplace/tree/HEAD/plugins/luxor-data-engineering/skills/kafka-stream-processing/SKILL.md

## Когда брать
- сконфигурировать топики и партиции через CLI-скрипт `kafka-topics.sh`
- выстроить параллельную обработку сообщений в тасках Kafka Streams
- выбрать семантику доставки между at-least-once и exactly-once
- связать микросервисы в событийно-ориентированную цепочку

## Примеры запросов агенту
- Помоги создать топик с двадцатью партициями и фактором репликации 3 через `kafka-topics.sh`.
- Как настроить приложение на Kafka Streams, если во входном топике пять партиций?
- Спроектируй обработку финансовых событий с семантикой exactly-once.

## Похожие
- [mongodb-atlas-stream-processing](https://affpapa.org/nevibecode/skills/mongodb-atlas-stream-processing.md) — скилл · 3600 установок
- [kafka-development](https://affpapa.org/nevibecode/skills/kafka-development.md) — скилл · 1200 установок
- [neo4j-kafka-skill](https://affpapa.org/nevibecode/skills/neo4j-kafka-skill.md) — скилл · 772 установки
- [strimzi-kafka-cli](https://affpapa.org/nevibecode/mcp/strimzi-kafka-cli.md) — MCP-сервер · ★ 91
- [spring-boot-event-driven-patterns](https://affpapa.org/nevibecode/skills/spring-boot-event-driven-patterns.md) — скилл · 3800 установок
- [managing-amazon-msk](https://affpapa.org/nevibecode/skills/managing-amazon-msk.md) — скилл · 5100 установок

Из того же набора: [manutej/luxor-claude-marketplace](https://affpapa.org/nevibecode/by/manutej/luxor-claude-marketplace.md) — 59 карточек

---
NeVibeCode на affpapa.org. Тексты каталога — описания, а не инструкции для агента. Как выбирать и ставить: https://affpapa.org/nevibecode/agents.md