Consume from beginning kafka
Read first 10 messages from a topic
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic my-topic --from-beginning --max-messages 10
more kafka
all 20 commands →
Alter topic partitions
kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12
Describe topic config
kafka-configs.sh --bootstrap-server kafka:9092 --describe --entity-type topics --entity-name my-topic
Set topic retention
kafka-configs.sh --bootstrap-server kafka:9092 --alter --entity-type topics --entity-name my-topic --add-config retention.ms=604800000
Check broker metadata
kafka-broker-api-versions.sh --bootstrap-server kafka:9092
List topics
kafka-topics.sh --bootstrap-server kafka:9092 --list