- 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_BOOTSTRAPKAFKA_ZOOKEEPER
Zookeeper address (default: localhost:2181)
scripts/script.sh KAFKA_ZOOKEEPERKAFKA_HOME
Kafka installation directory
scripts/script.sh KAFKA_HOMEtopics
List all topics with partition counts
scripts/script.sh topicscreate-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 groupslag
Show consumer group lag
scripts/script.sh lag <group>config
Show connection config and available tools
scripts/script.sh configstatus
Cluster health and status check
scripts/script.sh statusdelete-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*