**自:
第一步:進入kafka官網
按照自己的需求選擇版本,我這裡選擇 最新版的 2.4.0
最後成果:為了安全,適當的馬賽克不能少
配置 kafka
配置 server.properties
cd kafka_2.11-2.4.0
建立kafka 日誌目錄 mkdir logs
更改kafka 日誌目錄對映 vi config/server.properties
啟動kafka
啟動zookeeper
啟動kafka 之前需要先啟動zookeeper 否則會報錯
啟動命令:./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
-daemon:表示以守護程序的方式啟動。
啟動 kafka
啟動命令:./bin/kafka-server-start.sh -daemon config/server.properties
kafka 測試
#在本機建立kafka,副本數量為1,分割槽數量為1[root@kafka bin]# ./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
#檢視本機的topic
[root@kafka bin]# ./kafka-topics.sh --list --bootstrap-server localhost:9092
#傳送訊息到test
[root@kafka bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
>aaaa
>bbbb
>cccc
#開啟新的終端,進行讀取訊息測試,「--from-beginning」表示從開頭讀取
**自:
第一步:進入kafka官網
按照自己的需求選擇版本,我這裡選擇 最新版的 2.4.0
最後成果:為了安全,適當的馬賽克不能少
配置 kafka
配置 server.properties
cd kafka_2.11-2.4.0
建立kafka 日誌目錄 mkdir logs
更改kafka 日誌目錄對映 vi config/server.properties
啟動kafka
啟動zookeeper
啟動kafka 之前需要先啟動zookeeper 否則會報錯
啟動命令:./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
-daemon:表示以守護程序的方式啟動。
啟動 kafka
啟動命令:./bin/kafka-server-start.sh -daemon config/server.properties
kafka 安裝和配置
第一步 進入kafka官網 按照自己的需求選擇版本,我這裡選擇 最新版的 2.4.0 最後成果 為了安全,適當的馬賽克不能少 配置 kafka 配置 server.properties cd kafka 2.11 2.4.0 建立kafka 日誌目錄 mkdir logs 更改kafka 日誌目錄對...
kafka配置以及安裝
rm f consumer.properties server.properties producer.properties zookeeper.properties vi kafka config server.properties 修改broker.id 1,host.name kafka02 ...
kafka安裝與配置
以上兩個程式需一直開啟!第三步 建立主題,開啟cmd命令 路徑 kafka 2.10 0.10.0.0 命令 bin windows kafka topics.bat create zookeeper localhost 2181 replication factor 1 partitions 1 ...