Kafka&&Zookeeper基本管理命令

1. zookeeper管理命令

#啓動zookeeper
bin/zkServer.sh start（默認以zoo.cfg文件啓動）

bin/zkServer.sh start conf/zoo.cfg

#查看狀態
bin/zkServer.sh status

#從新啓動
bin/zkServer.sh restart

#中止zookeeper

bin/zkServer.sh stop

2. kafka管理命令

#啓動kafka
bin/kafka-server-start.sh config/server.properties &

bin/kafka-server-start.sh -daemon  config/server.properties

#中止kafka
bin/kafka-server-stop.sh

#生產者
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test    
 
#消費者
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test

# 若是須要從頭開始接收數據，須要添加--from-beginning參數
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic test

#建立topic
bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic topicA
 
#查看topic列表
bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181
 
#若是須要查看topic的詳細信息，須要使用describe命令
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic topicA
 
#若不指定topic，則查看全部topic
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181
 
#刪除topic
bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic topicA