kafka 安裝和配置

2022-02-04 09:44:16 字數 2679 閱讀 4951

第一步:進入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 ...