← 返回 Skills 市场
ckchzh

Kafka

作者 BytesAgain2 · GitHub ↗ · v3.0.1 · MIT-0
cross-platform ✓ 安全检测通过
446
总下载
0
收藏
2
当前安装
6
版本数
在 OpenClaw 中安装
/install kafka
功能描述
Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag.
使用说明 (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]

安全使用建议
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.
功能分析
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.
能力评估
✓ 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.
如何使用
  1. 确保已安装 OpenClaw（本地或 Docker 部署）
  2. 在对话框中输入安装命令：/install kafka
  3. 安装完成后，直接呼叫该 Skill 的名称或使用 /kafka 触发
  4. 根据 Skill 的参数说明提供必要输入，即可获得结构化输出
版本历史
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
元数据
Slug kafka
版本 3.0.1
许可证 MIT-0
累计安装 2
当前安装数 2
历史版本数 6
常见问题

Kafka 是什么？

Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag. 它是一个面向 Claude Code / OpenClaw 的 AI Agent Skill 插件，目前累计下载 446 次。

如何安装 Kafka？

在 OpenClaw 或 Claude Code 对话框中运行命令「/install kafka」即可一键安装，无需额外配置。

Kafka 是免费的吗？

是的，Kafka 完全免费，采用 MIT-0 许可证，可自由下载、安装和使用。

Kafka 支持哪些平台？

Kafka 跨平台运行，可在任意部署了 OpenClaw / Claude Code 的环境中使用（cross-platform）。

谁开发了 Kafka？

由 BytesAgain2（@ckchzh）开发并维护，当前版本 v3.0.1。

推荐 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.
⬇ 191113 · 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

💬 留言讨论