start-zookeeper-kafka
阿新 • • 發佈：2019-02-15
核心 href 輸出 ica cati windows tor replica 類別
目錄
- 前言
- 是什麽
- zooekeeper
- kafka
- 測試
前言
- 操作系統win10
- 安裝時間2019年01月
- java版本jdk1.8.0_191
- zooekeeper版本zookeeper-3.4.12
- kafka版本kafka_2.11-2.1.0
- 本次安裝為單機安裝
- 參考網址1
是什麽
kafka的特點
它是一個處理流式數據的”發布-訂閱“消息系統，實時高效處理流式數據，將數據安全存儲在分布式集群。
它是運行在集群上的，將流式記錄存儲在topics中，每個record由key,value和timestamp組成
kafka的概念
broker：kafka集群包含一個或者多個服務器，服務器就稱作broker
topic：發布到kafka集群的消息類別。
partition：每個topic劃分為多個partition。
producer：生產者，負責發布消息到broker
consumer：消費者，從broker獲取消息
(kafka的核心API:Producer/Consumer/Streams/Connector)
zooekeeper
官網下載壓縮包之後解壓
文件配置
- 進入conf目錄，復制zoo_sample.cfg並重命名為zoo.cfg，修改其中的dataDir為dataDir=E:\zookeeper-kafka\zookeeper-3.4.12\tmp
- 這裏的更改路徑，目錄可以改成自己喜歡的目錄哦
環境變量配置
| 操作 | 變量值 | 變量名 |
|---|---|---|
| 新建 | ZOOKEEPER_HOME | 解壓目錄 |
| 增加 | PATH | 解壓目錄\bin |
測試
cmd命令行窗口輸入
C:\Users\wahaha>zkServerkafka
官網下載壓縮包之後解壓
文件配置
- 進入config目錄，在server.properties文件中修改log.dirs為log.dirs=E:\zookeeper-kafka\kafka_2.11-2.1.0\tmp\kafka-logs（這裏的更改路徑，目錄也可以改成自己喜歡的目錄哦）
- 在server.properties文件中修改zookeeper.connect為zookeeper.connect=localhost:2181（這表示在本地運行，即Kafka會按照默認，在9092端口上運行，並連接zookeeper的默認端口：2181）
測試
在啟動Kafka服務器前，需要先運行zookeeper實例（zookeeper的測試部分的命令行）
E:\zookeeper-kafka\kafka_2.11-2.1.0>.\\bin\\windows\\kafka-server-start.bat .\\config\\server.properties測試
下面的測試命令需要先執行zooekeeper和kafka的測試部分的命令行
- 創建一個topic並命名（我這裏叫wahaha...haha）
E:\zookeeper-kafka\kafka_2.11-2.1.0>.\\bin\\windows\\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wahaha- 在topic下創建一個producer
E:\zookeeper-kafka\kafka_2.11-2.1.0>.\\bin\\windows\\kafka-console-producer.bat --broker-list localhost:9092 --topic wahaha- 在topic下創建一個consumer
E:\zookeeper-kafka\kafka_2.11-2.1.0>.\\bin\\windows\\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic wahaha --from-beginning- 在producer中輸入，之後會在consumer中輸出，撒花★,°:.☆(￣▽￣)/$:.°★
start-zookeeper-kafka