Kafka

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

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 | [e-mail]