kafka

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

Safety Notice

This listing is from the official public ClawHub registry. Review SKILL.md and referenced scripts before running.

Copy this and send it to your AI assistant to learn

Install skill "kafka" with this command: npx skills add ckchzh/kafka

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 <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 | hello@bytesagain.com

Source Transparency

This detail page is rendered from real SKILL.md content. Trust labels are metadata-based hints, not a safety guarantee.

Open Registry RecordOpen in ClawHub

Related Skills

Related by shared tags or category signals.

General

TailwindCss Complete Documentation

Complete Tailwind CSS documentation. Use when working with Tailwind CSS utility classes, responsive design, dark mode, animations, custom configurations, plugins, or styling questions. Covers all utility classes, modifiers, configuration options, and best practices.

Registry SourceRecently Updated
2K0Profile unavailable
General

openclaw2backup

一键备份和恢复 OpenClaw 工作空间、Skills 及配置，支持快速和完整备份、选择性恢复及备份管理。

Registry SourceRecently Updated
2240Profile unavailable
General

OpenClaw Session Model Switcher

Instantly switch the current OpenClaw session model; supports gpt, claude, qianwen, minimax, current model status, configured model listing, and restoring th...

Registry SourceRecently Updated
3011Profile unavailable
General

QWeather China

基于中国气象局数据的完整天气服务，通过和风天气API提供实时天气、天气预报、生活指数、空气质量等全方位天气信息。专为中国用户优化，数据更准确，功能更全面。

Registry SourceRecently Updated
3830Profile unavailable