Kafka 命令行操作

一些常用的 Kafka 的命令行操作。

列出所有 topic
1
2
$ kafka-topics.sh --zookeeper <zkAddress>:<zkPort>/<zkPath> 
--list
创建 topic
1
2
3
$ kafka-topics.sh --zookeeper <zkAddress>:<zkPort>/<zkPath> 
--create --topic <topic_name>
--replication-factor <factor_number> --partitions <partition_number>
描述 topic
1
2
$ kafka-topics.sh --zookeeper <zkAddress>:<zkPort>/<zkPath> 
--describe --topic <topic_name>
生产消息
1
2
$ kafka-console-producer.sh --bootstrap-server <kfAddress>:<kfPort> 
--topic <topic_name>
消费消息
1
2
$ kafka-console-consumer.sh --bootstrap-server <kfAddress>:<kfPort> 
--topic <topic_name> --from-beginning
深得我心!博主晚餐加鸡腿!