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 | [email protected]