（1）
開啟zookeeper集群 startzk.sh
（2）開啟kafka集群 start-kafka.sh
（3）開啟kafka視覺化介面 kafka-manager ： start-kafka-manager.sh
（4）生產者操作：
kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic //my-kafka-topic時topic的名字
（5）消費者操作：
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
（6）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
kafka相關命令操作
啟動kafka 到每個節點啟動 node01 nohup bin kafka server start.sh config server.properties node02 nohup bin kafka server start.sh config server.properties node03...
kafka相關命令
1.群起指令碼 bin bash case 1 in start stop esac 2.檢視主題 bin kafka topics.sh list zookeeper k8smaster 2181 3.建立主題 kafka topics.sh create zookeeper k8smaster ...
kafka命令列操作，topic相關命令
檢視當前伺服器中的所有topic bin kafka topics.sh zookeeper 主機 2181 list 建立topic bin kafka topics.sh zookeeper 主機 2181 create replication factor 3 partitions 1 top...