vim kafka/config/server.properties
#確保唯一broker.id=0
#允許刪除主題
delete.topic.enable=true
# 指定資料檔案所在目錄
log.dirs=/var/local/kafka/logs
#zookeeper 的連線位址
zookeeper.connect=localhost:2181
啟動kafka./bin/kafka-server-start.sh config/server.properties
#檢視程序,帶上全類名
jps -l
#建立主題,乙個分割槽,乙個備份
bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 1 --replication-factor 1 --topic first
#檢視kafka的主題
bin/kafka-topics.sh --list --zookeeper localhost:2181
#生產者產生資料
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first
#啟動消費者
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic first --from-beginning
不跟zk互動,改跟kafka互動,提高效率
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first --from-beginning
Kafka安裝啟動教程
前言 本文講如何安裝啟動kafka,並進行測試,其中zookeepr是kafka自帶的,本文基本按照官網文件進行安裝啟動的,並提出可能會出現的問題。官方文件 http 2 解壓到指定目錄 tar xzf kafka 2.11 1.1.0.tgz c opt 3 修改配置檔案 vim server.p...
Kafka安裝部署啟動
解壓安裝包 tar zxvf opt software kafka 2.11 2.4.1.tgz c opt module 修改解壓後的檔名稱 mv opt module kafka 2.11 2.4.1 opt module kafka在 opt module kafka目錄下建立logs資料夾 ...
kafka 後台啟動 Kafka的安裝與啟動
安裝 在mac上可以使用brew install kafka進行kafka的安裝,在安裝kafka時,會自動檢測有無zookpeer,如果沒有的話也會安裝乙個。啟動kafka 啟動kafka,首先要確保啟動zookpeer.進入kafka安裝目錄的bin目錄下執行 zookeeper server ...