kafka-2.12使用記錄

安裝kafka 2.12版本

下載安裝包

根據你的系統下載rpm /deb /zip包等等, 這里我使用的是rpm包
安裝命令 rpm -ivh kafka-2.12-1.nfs.x86_64.rpm

啟動內置Zookeeper

以下命令要寫在同一行上

/opt/kafka-2.12/bin/zookeeper-server-start.sh 
/opt/kafka-2.12/config/zookeeper.properties

啟動kafka服務器

以下命令要寫在同一行上

/opt/kafka-2.12/bin/kafka-server-start.sh
/opt/kafka-2.12/config/server.properties

使用kafka

創建和查看topic

創建一個單 partition分區，單 replication副本 的叫 topic2023 的主題

/opt/kafka-2.12/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1  --partitions 1 --topic topic2023

查看topic列表

/opt/kafka-2.12/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

創建1個消息生產者

命令輸入完后，可以繼續輸入 多行要發送的消息內容

/opt/kafka-2.12/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic2023

創建1個消息消費者

命令輸入完成后回車，可以看到控制臺顯示出訂閱到的消息內容

/opt/kafka-2.12/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic2023 --from-beginning

配置kafka允許外網訪問

需要進入config目錄，修改server.properties文件里的配置

修改listeners配置項

listeners指定kafka監聽的本地地址和端口，這里配置為0.0.0.0:9092表示監聽所有網絡接口

listeners = PLAINTEXT://0.0.0.0:9092

修改advertised.listeners配置項

advertised.listeners是用于向客戶端公布你的kafka訪問地址，需要配置為你的機器的外部IP和端口

advertised.listeners=PLAINTEXT://10.1.5.212:9092

測試zookeeper聯通性

可以使用prettyZoo客戶端工具測試訪問zk服務器

使用kafkaUI-lite在線瀏覽和測試kafka

什么是kafkaUI-lite

kafka-ui-lite是一個開源的kafka監控項目，可以在gitee下載.
提供了對kafka 、zookeeper 、redis的監控和管理功能，
支持在線瀏覽和管理kafka的 topic主題/kafka集群/group分組
支持在線發送kafka消息

使用kafkaUI-lite查看topic

使用kafkaUI-lite創建topic

使用kafkaUI-lite發送消息

使用kafkaUI-lite查看zookeeper信息