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=plaintext:
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
二.啟動
進入kafka_2.11-2.0.0目錄下執行
啟動zookeeper,單機版啟動kafka自帶的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka
bin/kafka-server-start.sh config/server.properties
建立topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-1025
檢視所有topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
檢視topic資訊
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-1025
建立生產者
bin/kafka-console-producer.sh --broker-list zk-master01:9092 --topic test-1025
建立消費者
bin/kafka-console-consumer.sh --bootstrap-server zk-master01:9092 --topic test-1025 --from-beginning
單機版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單機版安裝
參考文件 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...
精 Kafka單機版安裝與測試
偽分布式中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 h...