centos7 5 Kafka單機部署

ticktime=2000

initlimit=10

synclimit=5

datadir=/home/zookeeper-3.4.13/data

datalogdir=/home/zookeeper-3.4.13/log

clientport=2181

4、在設定的datadir路徑下新增檔案myid在這個檔案中echo1作為單機版的節點id

5、設定zookeeper啟動後，zookeeper.out日誌輸出位置

修改指令碼$zookeeper_home/bin/zkenv.sh

if [ "x$" = "x" ]

then

zoo_log_dir="/.../zookeeper/log"

fi啟動測試

1、進入$zookeeper_home/bin路徑下 ./zkserver.sh start

2、./zkserver.sh status檢視啟動狀態或者jps命令檢視服務。quorumpeermain表示zookeeper服務

11729 quorumpeermain

24982 jps

————————————————

export kafka_home=/home/kafka_2.12

export path=$path:$kafka_home/bin

命令列輸入kafka，tab鍵檢查是否自動提示bin目錄下命令檢查是否配置成功

3、修改配置檔案：$kafka_home/config目錄下的server.properties

設定如下引數，其他引數使用預設值，broker.id對應zookeeper中myid中的數值

broker.id=1

port=9092

host.name=localhost

# kafka**位址

listeners=plaintext://:9092

log.dirs=/home/panfudong/soft/kafka/kafka_2.12/kafka-logs

zookeeper.connect=localhost:2181

啟動測試

1、進入$kafka_home路徑

2、./bin/kafka-server-start.sh --daemon  config/server.properties啟動kafka

3、使用jps命令檢視程序出現kafka表明啟動成功

4、如果失敗去$kafka_home/logs下檢視server.log日誌

————————————————

步驟3：測試建立topic 

cd /usr/local/kafka/bin 

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

步驟4：通過list命令檢視建立的topic 

cd /usr/local/kafka/bin 

./kafka-topics.sh –list –zookeeper localhost:2181

步驟5：生產訊息測試 

[root@test bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test 

laoyang i love you!

步驟6：消費訊息測試 

[root@test bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 

laoyang i love you!

經過以上6步，代表kafka安裝成功。

centos7單機安裝kafka

基礎要求作業系統 centos 7x 64位 kafka版本 kafka 2.11 0.8.2.1 提取碼 ns3c 1 關閉selinux 開放防火牆9092埠 root wzy x vi etc selinux config root wzy x tail 2 etc selinux confi...

Kafka 單機kafka部署

1 上傳部署包 kafka 2.11 0.11.0.0.tgz 放到 opt software 2 解壓 tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 3 切換目錄 opt module kafka 2.11 0.11.0.0 conf 4 修改配置 v...

kafka單機部署

2 解壓 tar zxvf kafka 2.12 0.11.0.3.tgz c local sda kafka3 使用kafka自帶的zookeeper,修改zookeeper.properties cd local sda kafka kafka 2.12 0.11.0.3 進入kafka主目錄 ...