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

1.創(chuàng)建Topic

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

　　2181 是zookeeper 端口

　　圖示為創(chuàng)建成功：

　　

2.查看Topic

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

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

　　

3.用Kafka的console-producer在topic test1 生產(chǎn)消息

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

　　然后輸入想要產(chǎn)生的消息內(nèi)容（如 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，剛剛已經(jīng)消費過的消息還會被新終端繼續(xù)消費。也就是說，消息被消費過后不會立即被刪除。　　　　　　　　　　　

　　　　

?

總結(jié)

以上是生活随笔為你收集整理的Kafka创建查看topic，生产消费指定topic消息的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。