啟動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，剛剛已經消費過的消息還會被新終端繼續消費。也就是說，消息被消費過后不會立即被刪除。
