kafka
Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag.
Install via CLI (Recommended)
clawhub install openclaw/skills/skills/ckchzh/kafkakafka
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 <name> [p] [r]
describe
Detailed topic description
scripts/script.sh describe <topic>
produce
Produce a message (optional key)
scripts/script.sh produce <topic> <msg> [key]
consume
Consume messages (default: 10, from-beginning)
scripts/script.sh consume <topic> [count] [from]
groups
List all consumer groups
scripts/script.sh groups
lag
Show consumer group lag
scripts/script.sh lag <group>
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 <topic>
partitions
Increase topic partitions
scripts/script.sh partitions <topic> <count>
offsets
Show earliest/latest offsets
scripts/script.sh offsets <topic>
Requirements
- Kafka CLI tools
Powered by BytesAgain | bytesagain.com | [email protected]
Metadata
Not sure this is the right skill?
Describe what you want to build — we'll match you to the best skill from 16,000+ options.
Find the right skillPaste this into your clawhub.json to enable this plugin.
{
"plugins": {
"official-ckchzh-kafka": {
"enabled": true,
"auto_update": true
}
}
}Tags
Related Skills
skill-tracker
通用技能使用统计追踪器，支持 Python 和 Node.js 技能，自动记录调用次数、成功率，生成使用排行榜。数据本地存储，保护隐私。
cmms
Computerized maintenance management system
consent
Build cookie consent banners and track opt-in compliance status. Use when implementing GDPR consent, auditing cookies, generating privacy banners.
amr
Autonomous mobile robot fleet manager. Use when json amr tasks, csv amr tasks, checking amr status.
breaker
Circuit breaker sizing and coordination tool. Use when json breaker tasks, csv breaker tasks, checking breaker status.