Kafka簡單部署操作

2021-07-13 15:14:29 字數 1556 閱讀 8020

啟動kafka需要先啟動zk，推薦手動啟動zk，不用kafka的命令

配置檔案zookeeper.properties

配置項

datadir：zk datadir 配置的目錄

clientport：zk埠

bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka

broker配置檔案server.properties

配置項

broker.id： broker唯一整型標識

port： socket監聽，不能被占用

log.dirs：日誌存放檔案路徑

zookeeper.connect： zk的ip:port(/path)

bin/kafka-server-start.sh config/server.properties
啟動kafka後會在zk上建立節點[admin, consumers, controller, controller_epoch, brokers, config]

停止kafka

bin/kafka-server-stop.sh
建立topic

bin/kafka-topics.sh --create --zookeeper localhost:2343/hellokafka --replication-factor 1 --partitions 1 --topic test
建立成功：created topic 「test」. zk上新增對應節點

[zk: localhost:2343(connected) 15] ls /hellokafka/brokers/topics 


[test]
也可通過kafka命令檢視

bin/kafka-topics.sh --list --zookeeper localhost:2343/hellokafka
刪除topic，會在/hellokafka/admin/delete_topics下新增該topic節點，要在配置檔案中將delete.topic.enable設為true才會真正刪除

bin/kafka-topics.sh --zookeeper localhost:2343/hellokafka --delete --topic test
傳送訊息

bin/kafka-console-producer.sh --broker-list localhost:9090 --topic test2
消費訊息

bin/kafka-console-consumer.sh --zookeeper localhost:2343/hellokafka --topic test2 --from-beginning
此時在生產端控制台輸入的訊息會在消費端輸出

KAFKA簡單操作

1.建立乙個topic,3個分割槽和兩個副本 redis node1 kafka 2.12 2.2.0 bin kafka topics.sh create zookeeper node1 2181 replication factor 2 partitions 3 topic test 2.檢視t...

Kafka集群部署及簡單使用

1 解壓安裝包 atguigu hadoop102 software tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 2 修改解壓後的檔名稱 atguigu hadoop102 module mv kafka 2.11 0.11.0.0 kafka 3 在...

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