安裝啟動kafka

2022-06-28 06:09:10 字數 927 閱讀 4245

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 ...