Agent skill
kafka
Manage Apache Kafka — topics, consumer groups, and produce/consume messages via the Confluent REST Proxy.
Install this agent skill to your Project
npx add-skill https://github.com/majiayu000/claude-skill-registry/tree/main/skills/other/other/kafka
Metadata
Additional technical details for this skill
- thinkfleetbot
-
{ "emoji": "\ud83d\udce8", "requires": { "env": [], "bins": [ "curl", "jq" ] } }
SKILL.md
Apache Kafka
Manage topics, consumer groups, and messages via the Confluent REST Proxy.
List topics
curl -s "http://localhost:8082/topics" | jq '.[]'
Get topic details
curl -s "http://localhost:8082/topics/TOPIC_NAME" | jq '{name, partitions: (.partitions | length), configs}'
Produce message
curl -s -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" \
"http://localhost:8082/topics/TOPIC_NAME" \
-d '{"records":[{"key":"key1","value":{"message":"hello"}}]}' | jq '.offsets[]'
Create consumer
curl -s -X POST -H "Content-Type: application/vnd.kafka.v2+json" \
"http://localhost:8082/consumers/my-group" \
-d '{"name":"my-consumer","format":"json","auto.offset.reset":"earliest"}' | jq '{instance_id, base_uri}'
Consume messages
curl -s -H "Accept: application/vnd.kafka.json.v2+json" \
"http://localhost:8082/consumers/my-group/instances/my-consumer/records" | jq '.[] | {topic, key, value, offset}'
Notes
- Requires Confluent REST Proxy running (default port 8082).
- Always confirm before producing messages.
Recommended Agent Skills
Expand your agent's capabilities with these related and highly-rated skills.
majiayu000/claude-skill-registry
agent-ops-spec
Manage specification documents in .agent/specs/. Use when user provides requirements, acceptance criteria, or feature descriptions that need to be tracked and validated against implementation.
majiayu000/claude-skill-registry
agent-ops-state
Maintain .agent state files. Use at session start, after meaningful steps, and before concluding: read/update constitution/memory/focus/issues/baseline consistently.
majiayu000/claude-skill-registry
agent-ops-spec
Manage specification documents in .agent/specs/. Use when user provides requirements, acceptance criteria, or feature descriptions that need to be tracked and validated against implementation.
majiayu000/claude-skill-registry
agent-ops-testing
Test strategy, execution, and coverage analysis. Use when designing tests, running test suites, or analyzing test results beyond baseline checks.
majiayu000/claude-skill-registry
agent-ops-testing
Test strategy, execution, and coverage analysis. Use when designing tests, running test suites, or analyzing test results beyond baseline checks.
majiayu000/claude-skill-registry
agent-ops-state
Maintain .agent state files. Use at session start, after meaningful steps, and before concluding: read/update constitution/memory/focus/issues/baseline consistently.
Didn't find tool you were looking for?