Kafka

---

name: kafka version: "3.0.1" author: BytesAgain homepage: https://bytesagain.com source: https://github.com/bytesagain/ai-skills license: MIT-0 tags: [kafka, tool, utility] description: "Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag."

---

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  [p] [r]

describe

Detailed topic description

scripts/script.sh describe 

produce

Produce a message (optional key)

scripts/script.sh produce   [key]

consume

Consume messages (default: 10, from-beginning)

scripts/script.sh consume  [count] [from]

groups

List all consumer groups

scripts/script.sh groups

lag

Show consumer group lag

scripts/script.sh lag 

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 

partitions

Increase topic partitions

scripts/script.sh partitions  

offsets

Show earliest/latest offsets

scripts/script.sh offsets 

Requirements

Kafka CLI tools

---

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