1，開啟zookeeper叢集 startzk.sh
2，開啟kafka叢集  start-kafka.sh
2，開啟kafka視覺化介面 kafka-manager ： start-kafka-manager.sh

3,生產者操作：
kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic    //my-kafka-topic時topic的名字

4,消費者操作：
kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic
# 通過以上命令，可以看到消費者可以接收生產者傳送的訊息

# 如果需要從頭開始接收資料，需要新增--from-beginning引數
kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic


5,a.建立topic
kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic

b.檢視topic列表
kafka-topics.sh --list --zookeeper node01:2181

c.如果需要檢視topic的詳細資訊，需要使用describe命令
kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic

d.#若不指定topic，則檢視所有topic的資訊
kafka-topics.sh --describe --zookeeper node1:2181

e.刪除topic
kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic