← Back to Skills Marketplace
ckchzh

Kafka

by BytesAgain2 · GitHub ↗ · v3.0.1 · MIT-0
cross-platform ✓ Security Clean
446
Downloads
0
Stars
2
Active Installs
6
Versions
Install in OpenClaw
/install kafka
Description
Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag.
README (SKILL.md)

kafka

Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag.

Commands

KAFKA_BOOTSTRAP

Bootstrap servers (default: localhost:9092)

scripts/script.sh KAFKA_BOOTSTRAP

KAFKA_ZOOKEEPER

Zookeeper address (default: localhost:2181)

scripts/script.sh KAFKA_ZOOKEEPER

KAFKA_HOME

Kafka installation directory

scripts/script.sh KAFKA_HOME

topics

List all topics with partition counts

scripts/script.sh topics

create-topic

Create topic (partitions, replication factor)

scripts/script.sh create-topic \x3Cname> [p] [r]

describe

Detailed topic description

scripts/script.sh describe \x3Ctopic>

produce

Produce a message (optional key)

scripts/script.sh produce \x3Ctopic> \x3Cmsg> [key]

consume

Consume messages (default: 10, from-beginning)

scripts/script.sh consume \x3Ctopic> [count] [from]

groups

List all consumer groups

scripts/script.sh groups

lag

Show consumer group lag

scripts/script.sh lag \x3Cgroup>

config

Show connection config and available tools

scripts/script.sh config

status

Cluster health and status check

scripts/script.sh status

delete-topic

Delete a topic (with confirmation)

scripts/script.sh delete-topic \x3Ctopic>

partitions

Increase topic partitions

scripts/script.sh partitions \x3Ctopic> \x3Ccount>

offsets

Show earliest/latest offsets

scripts/script.sh offsets \x3Ctopic>

Requirements

  • Kafka CLI tools

Powered by BytesAgain | bytesagain.com | [email protected]

Usage Guidance
This skill appears to do what it says: it wraps your local Kafka CLI tools. Before installing/using it: (1) ensure you have the kafka-*.sh CLI tools available or install Kafka; (2) inspect scripts/script.sh yourself (it will create ~/.local/share/kafka-helper and a log file) and confirm you trust it; (3) if connecting to a secured Kafka cluster, be careful with KAFKA_CONFIG_FILE — it can contain credentials or TLS settings, so point it to a safe config; (4) run the script in a controlled environment (or with non-production Kafka) the first time to confirm behavior. If you want tighter control, set explicit KAFKA_BOOTSTRAP/KAFKA_HOME rather than relying on defaults or global config files.
Capability Analysis
Type: OpenClaw Skill Name: kafka Version: 3.0.1 The Kafka skill bundle is a legitimate utility for managing Apache Kafka clusters, providing a bash wrapper (scripts/script.sh) for standard CLI tools. It implements expected features like topic creation, message production/consumption, and lag monitoring without any signs of data exfiltration, persistence, or malicious execution. The script follows safe shell practices, such as using arrays for command construction to prevent injection, and limits its local footprint to a standard log directory in the user's home folder.
Capability Assessment
✓ Purpose & Capability
Name/description match the implementation: the script invokes standard kafka-*.sh CLI tools to list/create/describ e/produce/consume, manage partitions and consumer groups, and report lag. Optional environment variables the script honors (KAFKA_BOOTSTRAP, KAFKA_ZOOKEEPER, KAFKA_HOME, KAFKA_CONFIG_FILE) are appropriate for configuring Kafka access.
ℹ Instruction Scope
SKILL.md instructs invoking scripts/script.sh for all operations, which is consistent with the included script. Minor mismatch: the registry metadata lists no required env vars but the script reads optional env vars (KAFKA_BOOTSTRAP, KAFKA_ZOOKEEPER, KAFKA_HOME, KAFKA_CONFIG_FILE); these are reasonable for configuring Kafka but users should be aware they control the script's targets. The script writes a local data dir (~/.local/share/kafka-helper) and log file.
✓ Install Mechanism
No install spec — instruction-only skill with an included helper script. It does not download code at runtime or fetch external archives. Risk is limited to executing the included shell script and the local Kafka CLI tools it calls.
ℹ Credentials
The skill does not require credentials from the registry metadata. It optionally uses KAFKA_CONFIG_FILE which may contain connection/security settings (e.g., SASL/SSL configs) — this is proportional to connecting to secured Kafka clusters but users should ensure any config file referenced is trusted. No unrelated service tokens or secrets are requested.
✓ Persistence & Privilege
The skill is not always-enabled and does not modify other skills or global agent settings. It creates a per-user data directory and log file under $HOME, which is expected for a CLI helper and is not an elevated privilege.
How to Use
  1. Make sure OpenClaw is installed (local or Docker)
  2. Run the install command in chat: /install kafka
  3. After installation, invoke the skill by name or use /kafka
  4. Provide required inputs per the skill's parameter spec and get structured output
Version History
v3.0.1
v3.0.1: SKILL.md rewritten to match new script commands.
v3.0.0
v3.0.0: Complete rewrite with real kafka functionality.
v2.0.1
update
v2.0.0
v2.5 retry: desc+homepage+source+security
v1.0.1
retry-fix-token
v1.0.0
Initial release
Metadata
Slug kafka
Version 3.0.1
License MIT-0
All-time Installs 2
Active Installs 2
Total Versions 6
Frequently Asked Questions

What is Kafka?

Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag. It is an AI Agent Skill for Claude Code / OpenClaw, with 446 downloads so far.

How do I install Kafka?

Run "/install kafka" in the OpenClaw or Claude Code chat to install it in one step — no extra setup required.

Is Kafka free?

Yes, Kafka is completely free, licensed under MIT-0. You can download, install and use it at no cost.

Which platforms does Kafka support?

Kafka is cross-platform and runs anywhere OpenClaw / Claude Code is available (cross-platform).

Who created Kafka?

It is built and maintained by BytesAgain2 (@ckchzh); the current version is v3.0.1.

More Skills
self-improving agent
Captures learnings, errors, and corrections to enable continuous improvement. Use when: (1) A command or operation fails unexpectedly, (2) User corrects Clau...
⬇ 463283 · by pskoett
Skill Vetter
Security-first skill vetting for AI agents. Use before installing any skill from ClawdHub, GitHub, or other sources. Checks for red flags, permission scope, and suspicious patterns.
⬇ 259410 · by spclaudehome
Polymarket
Query Polymarket prediction markets. Check odds, find trending markets, search events, track price movements.
⬇ 232503 · by joelchance
Self-Improving + Proactive Agent
Self-reflection + Self-criticism + Self-learning + Self-organizing memory. Agent evaluates its own work, catches mistakes, and improves permanently. Use when...
⬇ 200423 · by ivangdavila
Github
Interact with GitHub using the `gh` CLI. Use `gh issue`, `gh pr`, `gh run`, and `gh api` for issues, PRs, CI runs, and advanced queries.
⬇ 191115 · by steipete
ontology
Typed knowledge graph for structured agent memory and composable skills. Use when creating/querying entities (Person, Project, Task, Event, Document), linkin...
⬇ 190156 · by oswalpalash

💬 Comments