kafka單機部署

2021-09-26 07:37:29 字數 1582 閱讀 3973

2、解壓

tar -zxvf kafka_2.12-0.11.0.3.tgz  -c  /local/sda/kafka
3、使用kafka自帶的zookeeper, 修改zookeeper.properties

cd /local/sda/kafka/kafka_2.12-0.11.0.3  #進入kafka主目錄


mkdir -p zk/data #建立zookeeper資料存放目錄


mkdir -p zk/logs #建立zookeeperl存放日誌目錄


cd config #進入配置檔案所在目錄


# vim 修改zookeeper.properties :


ticktime=2000


datadir=/local/sda/kafka/kafka_2.12-0.11.0.3/zk/data


datalogdir=/local/sda/kafka/kafka_2.12-0.11.0.3/zk/logs


clientport=2181


####################
4、修改server.properties

# 本地試執行，修改這兩個就行


listeners=plaintext://localhost:9092


zookeeper.connect=localhost:2181
5、啟動和停止

# 啟動：


./zookeeper-server-start.sh -daemon ../config/zookeeper.properties #啟動zookeeper


./kafka-server-start.sh -daemon ../config/server.properties #啟動kafka


# 停止


./zookeeper-server-stop.sh #停止zookeeper


./kafka-server-stop.sh #停止kafka，centos7上可能關不了用kill -9直接殺掉


# jps檢視是否有zookeeper和kafka程序


jps
6.測試是否可用

建立topics：

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test
在一台上建立生產者：

./kafka-console-producer.sh --broker-list localhost:9092 --topic test
在另一台上建立消費者：

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
正常的話，生產者中輸入的內容，會在消費者端輸出。

附上kafka命令大全：

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 單機部署

kafka 單機部署區分整合zookeeper 部署和zookeeper kafka 部署倆總方式，如果是單機部署kafka，整合zookeeper 最簡單，也可以選擇zookeeper kafka 這種模式，但是如果為kafka集群的話，則必須需要部署 zookeeper 集群。一.獲取解壓wge...

Kafka單機模式部署

安裝步驟見 zookeeper部署 解壓包上傳至linux伺服器opt目錄下 cd opt 解壓tgz包 tar xvf kafka 2.12 2.3.0.tgz 修改server.properties配置檔案 vi opt kafka 2.12 2.3.0 config server.proper...