Kafka

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

BytesAgain2@ckchzh

Install

openclaw skills install @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)

bash

scripts/script.sh KAFKA_BOOTSTRAP

`KAFKA_ZOOKEEPER`

Zookeeper address (default: localhost:2181)

bash

scripts/script.sh KAFKA_ZOOKEEPER

`KAFKA_HOME`

Kafka installation directory

bash

scripts/script.sh KAFKA_HOME

`topics`

List all topics with partition counts

bash

scripts/script.sh topics

`create-topic`

Create topic (partitions, replication factor)

bash

scripts/script.sh create-topic <name> [p] [r]

`describe`

Detailed topic description

bash

scripts/script.sh describe <topic>

`produce`

Produce a message (optional key)

bash

scripts/script.sh produce <topic> <msg> [key]

`consume`

Consume messages (default: 10, from-beginning)

bash

scripts/script.sh consume <topic> [count] [from]

`groups`

List all consumer groups

bash

scripts/script.sh groups

`lag`

Show consumer group lag

bash

scripts/script.sh lag <group>

`config`

Show connection config and available tools

bash

scripts/script.sh config

`status`

Cluster health and status check

bash

scripts/script.sh status

`delete-topic`

Delete a topic (with confirmation)

bash

scripts/script.sh delete-topic <topic>

`partitions`

Increase topic partitions

bash

scripts/script.sh partitions <topic> <count>

`offsets`

Show earliest/latest offsets

bash

scripts/script.sh offsets <topic>

Requirements

Kafka CLI tools

Powered by BytesAgain | bytesagain.com | hello@bytesagain.com