在此目錄下運行命令
/opt/kafka_2.12-2.2.0/
啟動內置的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka服務
bin/kafka-server-start.sh config/server.properties
創建topic話題
bin/kafka-topics.sh --create --topic 1709d --bootstrap-server 192.168.5.128:9092 -partitions 3 -replication-factor 1
查看所有topic話題
bin/kafka-topics.sh --list --bootstrap-server 192.168.5.128:9092
查看指定話題的詳情
bin/kafka-topics.sh --bootstrap-server 192.168.5.128:9092 --describe --topic 1709d
創建生產者
bin/kafka-console-producer.sh --broker-list 192.168.5.128:9092 --topic 1709d
創建消費者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.5.128:9092 --topic 1709d
使用外置的zookeeper，內置和外置只需要開一個即可
以下命令是在此目錄下運行
/opt/zookeeper-3.4.14
啟動zookeeper
bin/zkServer.sh start
查看zookeeper狀態
bin/zkServer.sh status
停止zookeeper
bin/zkServer.sh stop