Kafka Streams — Architect, Build, Debug Agent Skill
Architect, build, and debug Kafka Streams apps (JVM-embedded stream processing).
- Context cost
- 47.9k tokensestimated from the bundle, loaded when it triggers
- Bundle
- 17 files · 204.9 kB4 scripts among them — read before you run
- Licence
- Apache-2.0the author’s own terms
- Last change
- —v1.0.0
- Servers it uses
- Noneruns standalone
What it does
Architect, build, and debug Kafka Streams apps (JVM-embedded stream processing). Use when user mentions KStream, KTable, topology, TopologyTestDriver, StreamsBuilder, interactive queries, GlobalKTable, joins/windows/aggregations, or debugging issues (rebalancing, state stores, lag, deserialization errors). Also use when user wants to optimize Kafka Streams for WarpStream or tune Kafka Streams client configuration for WarpStream. Do NOT trigger for Flink, connectors, CDC, or plain producer/consumer.
Installed, it changes the agent in these ways.
What this skill changes about the agent has not been set out here as a list. Its SKILL.md, shown below, says it in the author’s own words.
And these are the jobs people reach for it for.
The skill itself
A skill is instructions the model reads, so you can see what you are getting: below is the start of its SKILL.md. The front matter loads with every session, the body loads when the skill triggers, and the whole file comes with the install.
Nothing in a skill executes. The client loads the text and the model follows it, so a skill can be audited the way a runbook is — by reading it.
What it costs in context
Skills are not billed by the call. They are paid for in context: every token the instructions occupy is a token your code, your diff and your conversation cannot use. Here is what this one takes and when it takes it.
47.9k tokens, estimated from the bundle at four bytes to the token, held for the rest of the session once it triggers. Heavy. Teams tend to install this one per project rather than globally, and load it only when the job comes up.
A server charges by the month. A skill charges once per session, in context, and then keeps charging it for as long as the session lives.
Before and after
The same question, put to the same model twice: once as it comes, and once with these instructions loaded.
No worked example has been published for this skill yet.
The procedure it runs
The procedure has not been set out here step by step. It is in the body of its SKILL.md: the start of it is shown above, and the whole file comes with the install.
These steps are written for a model to follow, not executed by a runtime. It can still be told to skip one, and it will say so when it does.
Servers it uses
None. This skill calls no MCP servers at all.
Everything it needs is in the instructions, so it works in a project with nothing connected — the model reads the file and changes how it works with what it can already reach.
Its SKILL.md does not declare which tools it asks the agent for, so what it touches is whatever the instructions themselves ask for — read them before you install it.
This SKILL.md carries no allowed-tools line, so neither is declared. A skill grants no permissions of its own — it can only ask for tools your client already has.
What it will not do
Every skill is narrow, and the useful ones say where they stop. These are the jobs this one is the wrong tool for.
What this skill is not for has not been published here. Nothing is implied by that: it is a section the author has not filled in.
What is in the bundle
17 files, 204.9 kB on disk. Mostly text — the instructions the model reads — with 4 scripts in it that your client would run only if the instructions tell it to.
- SKILL.md15.7 kB
- evals/evals.json35.0 kB
- references/architecture.md7.0 kB
- references/build-templates.md14.7 kB
- references/cli-commands.md6.1 kB
- references/config-baseline.md14.8 kB
- references/debugging.md29.0 kB
- references/docker-compose.md6.3 kB
- references/production-hardening.md13.8 kB
- references/schema-patterns.md11.2 kB
- references/topology-patterns.md16.8 kB
- references/verification.md9.3 kB
- references/warpstream-optimization.md11.9 kB
- scripts/create-topics.sh4.7 kB
- scripts/produce-test-data.sh2.4 kB
- scripts/teardown.sh3.4 kB
- scripts/verify-output.sh2.8 kB
A skill installs nothing and depends on nothing: it is a folder your client reads. This one carries 4 scripts beside the text, so the bundle is 17 files you can review in full before installing. The Apache-2.0 licence covers the templates and examples as well as the instructions.
Install
Installing copies the bundle into your project. Nothing runs at install time — the files sit on disk until the model reads them.
# Kafka Streams — Architect, Build, Debug · 47.9k tokens when loaded · macOS, Linux
mkdir -p .claude/skills && t=$(mktemp -d) &&
curl -fsSL -o "$t/bundle.tar.gz" https://mcprush.com/api/skills/kafka-streams-architect-build-debug/bundle.tar.gz &&
tar -xzf "$t/bundle.tar.gz" -C "$t" && [ -d "$t/kafka-streams-architect-build-debug" ] &&
{ [ ! -e .claude/skills/kafka-streams-architect-build-debug ] || { mv .claude/skills/kafka-streams-architect-build-debug "$t/.previous" && echo "Previous copy moved to $t/.previous"; }; } &&
mv "$t/kafka-streams-architect-build-debug" .claude/skills/ && echo "Installed .claude/skills/kafka-streams-architect-build-debug"npx mcprush@latest skill add confluentinc/kafka-streams-architect-build-debugWindows PowerShell says 'running scripts is disabled on this system'? Run Set-ExecutionPolicy -Scope CurrentUser RemoteSigned once, or type npx.cmd instead of npx (codex.cmd, gemini.cmd, grok.cmd likewise). PowerShell 7 needs neither. Writes to .claude/skills/kafka-streams-architect-build-debug/ in the current project. For every project instead, run mkdir -p ~/.claude/skills && t=$(mktemp -d) && curl -fsSL -o "$t/bundle.tar.gz" https://mcprush.com/api/skills/kafka-streams-architect-build-debug/bundle.tar.gz && tar -xzf "$t/bundle.tar.gz" -C "$t" && [ -d "$t/kafka-streams-architect-build-debug" ] && { [ ! -e ~/.claude/skills/kafka-streams-architect-build-debug ] || { mv ~/.claude/skills/kafka-streams-architect-build-debug "$t/.previous" && echo "Previous copy moved to $t/.previous"; }; } && mv "$t/kafka-streams-architect-build-debug" ~/.claude/skills/ && echo "Installed ~/.claude/skills/kafka-streams-architect-build-debug" (macOS, Linux) — or add --global to the npx line. The curl line replaces .claude/skills/kafka-streams-architect-build-debug/ only after the download succeeds, so files left there by another skill of the same name, or by an older release, do not mix in. A copy already there is moved aside, not deleted, and the line prints where. It appears as kafka-streams-programming in Gemini CLI, Codex, Copilot and Grok (its own name); Claude Code lists it by the folder name, kafka-streams-architect-build-debug.
Which clients pick it up on their own
A skill is a folder of text. Most of these read a skills folder and pick it up without being told; the rest take the same folder another way — an upload in the app, a parameter on an API call — and then choose it by its description just the same.
Versions
v1.0.0 is what is on the shelf; no release here carries a date. Instructions change more often than APIs do — a skill can be rewritten entirely without anything it depends on moving.
- No earlier releases have been published to the marketplace.
The install command always fetches the release that is current the day you run it — v1.0.0 today — and cannot ask for an earlier one. The copy on your disk does not change until you run it again.
Reviews
Nobody has reviewed this skill yet. The rating is the mean of the reviews written here, so there is none until somebody writes the first.
A review is tied to an account so it can be answered, edited and taken down by the person who wrote it.
Sign inAnybody with an account, one review each. It carries the version that was current when you wrote it, and the publisher may reply once.