啟動zookeeper和Kafka之後，進入kafka目錄（安裝/啟動kafka參考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html）

1.創建Topic

　　1）運行命令： ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

　　2181 是zookeeper 端口

　　圖示為創建成功：

2.查看Topic

　　1）運行命令查看所有的topic： ./bin/kafka-topics.sh --list --zookeeper localhost:2181

　　結果如下圖，表示共有test和test1兩個topic：

3.用Kafka的console-producer在topic test1 生產消息

　　新建終端窗口，到/Applications/kafka目錄，運行命令：./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

　　然後輸入想要產生的消息內容（如 hello world），回車：

4.用Kafka的console-consumer 消費topic test1的消息

　　新建終端窗口，到/Applications/kafka目錄，

　　運行命令：./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning

　　（9092是kafka單機啟動的端口；--bootstrap-server 新舊kafka版本不一樣，這個是新版本的命令）

　　ps. 1)若producer 和 consumer 兩個窗口同時打開，在producer輸入信息，consumer會立即消費信息並打印在終端

　　　 2）新開一個終端，去消費同一個topic，剛剛已經消費過的消息還會被新終端繼續消費。也就是說，消息被消費過後不會立即被刪除。　　　　　　　　　　　

Kafka創建&查看topic，生產&消費指定topic消息