偽分布式中kafka中已經整合了zookeeper
2.解壓kafka
tar -zxvf kafka_2.11-0.10.0.1.tgz
3.移動到下面資料夾
/home/software/kafka_2.11-0.10.0.1
4.配置檔案
vi /etc/profile
export kafka_home=/home/software/kafka_2.11-0.10.0.1
export path=$path:$kafka_home/bin
source /etc/profile
5.修改zk的log位址
在kafka目錄下
cd config
vim zookeeper.properties
datadir=/home/data/zookeeper
6.啟動kafka
單機模式-kafka自然整合zk
zk config路徑
/home/software/kafka_2.11-0.10.0.1/config/zookeeper.properties
在kafka目錄下
cd bin
(1)啟動zk
nohup zookeeper-server-start.sh /home/software/kafka_2.11-0.10.0.1/config/zookeeper.properties &
(2)啟動broker
nohup kafka-server-start.sh /home/software/kafka_2.11-0.10.0.1/config/server.properties &
7.啟動成功
8.準備測試
(1).建立主題
kafka-topics.sh --create --zookeeper localhost:2181 --topic mytopic --partitions 1 --replication-factor 1
--create 執行的動作
--zookeeper 主題寫入位置
--topic 主題
--partitions 物理分割槽
--replication-factor 副本因子
(2).建立生產者
kafka-console-producer.sh --broker-list 192.168.56.102:9092,192.168.56.103:9092,192.168.56.104:9092 --topic mytopic
(3).建立消費者
kafka-console-consumer.sh --zookeeper192.168.56.101:2181 --topic mytopic
(4).傳送訊息
單機版kafka安裝
export server kafka kafka安裝需要有zookeeper註冊中心 其中 zookeeper的安裝 見centos7安裝偽分布式zookeeper root vm 0 2 centos kafka wget2.解壓 root vm 0 2 centos kafka tar zxv...
單機版kafka安裝
wget解壓安裝包 tar xzvf kafka 2.11 2.0.0.tgz修改server.properties檔案 vim kafka 2.11 2.0.0 config server.properties listeners plaintext advertised.listeners pl...
kafka單機版安裝
參考文件 192.168.1.183 centos 6.5 2.6.32 431.el6.x86 64 三部曲 jdk zookeeper kafka 嚴格的安裝順序 wget wget 1 基本的系統操作 關閉防火牆 時間同步 相關工具.2 安裝jdk root kafka cd usr loca...