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

1.創(chuàng)建Topic

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

　　2181 是zookeeper 端口

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

　　

2.查看Topic

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

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

　　

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

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

　　然后輸入想要產(chǎn)生的消息內(nèi)容（如 hello world），回車(chē)：

　　　　

4.用Kafka的console-consumer 消費(fèi)topic test1的消息

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

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

　　（9092是kafka單機(jī)啟動(dòng)的端口；--bootstrap-server ? 新舊kafka版本不一樣，這個(gè)是新版本的命令）

　　

　　ps. 1)若producer 和 consumer 兩個(gè)窗口同時(shí)打開(kāi)，在producer輸入信息，consumer會(huì)立即消費(fèi)信息并打印在終端

　　　 ?2）新開(kāi)一個(gè)終端，去消費(fèi)同一個(gè)topic，剛剛已經(jīng)消費(fèi)過(guò)的消息還會(huì)被新終端繼續(xù)消費(fèi)。也就是說(shuō)，消息被消費(fèi)過(guò)后不會(huì)立即被刪除。　　　　　　　　　　　

　　　　

?

總結(jié)

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

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