理論
Kafka 是一款開源的、輕量級的、分布式、可磁區和具有復制備份的(Replicated)、基于ZooKeeper 協調管理的分布式流平臺的功能強大的訊息系統，與傳統的訊息系統相比，Kafka能夠很好地處理活躍的流資料，使得資料在各個子系統中高性能、低延遲地不停流轉，
Kafka定位就是一個分布式流處理平臺，作為一個流式處理平臺，必須具備以下3個關鍵特性，
? 能夠允許發布和訂閱流資料，從這個角度來講，平臺更像一個訊息佇列或者企業級的訊息系統，
? 存盤流資料時提供相應的容錯機制，
? 當流資料到達時能夠被及時處理，
案例
提示：可根據實際環境需求對選項、引數進行優化
需求：通過Kafka實作資料發布，客戶端能及時收到訂閱的資料，
安裝zookeeper
1、 下載或上傳軟體包并解壓
tar -xf zookeeper-3.4.9.tar.gz
移動并重命名
mv zookeeper-3.4.9 /usr/local/zookeeper
2、 編輯配置
1）進入樣例目錄
cd /usr/local/zookeeper/conf/
2）加-p拷貝（保留源檔案權限）
cp -p zoo_sample.cfg zoo.cfg
3、 宣告節點id號
echo 1 > /usr/local/zookeeper/data/myid
4、 修改默認腳本檔案
1）修改日志檔案存放路徑和查詢的方式為輪詢
vim zkEnv.sh
2）vim zkServer.sh
3）vim zkCli.sh
5、優化，創建軟連接到系統程式默認搜索路徑
ln -s zkServer.sh /usr/local/bin/
ln -s zkCli.sh /usr/local/bin/
6、在當前路徑啟動服務
[root@localhost bin]# ./zkServer.sh start
7、驗證：
安裝kafka
1、下載或上傳軟體包并解壓
tar xf kafka_2.11-2.2.1.tgz
移動并重命名
mv kafka_2.11-2.2.1 /usr/local/kafka
2、進入執行程式檔案目錄
cd /usr/local/kafka/bin/
3、以后臺運行方式啟動服務，并要指定其組態檔
4、查看埠，驗證服務啟動是否正常
5、測驗
1）producer使用localhost主機和9092埠，名稱為test
[root@localhost bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
輸入內容：看見我你就成功啦 ##訊息內容自定義，如圖：
2）輸入完成后新打開一個終端，作為訊息接受者
cd /usr/local/kafka/bin/
[root@localhost bin]# ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
看到我們剛才發送的訊息
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/336190.html
標籤：其他