kafka常用命令

1、查看當前服務器中的所有topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
2、創建topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
3、刪除topic
sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test
需要server.properties中設置delete.topic.enable=true否則只是標記刪除或者直接重啟。
4、通過shell命令發送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
5、通過shell消費消息
sh kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test
6、查看消費位置
sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup
7、查看某個Top的詳情
sh kafka-topics.sh --topic test --describe --zookeeper zk01:2181
8、對分區數進行修改
kafka-topics.sh --zookeeper zk01 --alter --partitions 15 --topic utopic