kafka是乙個高吞吐量的訊息系統。隔離訊息接收和處理過程（可理解為乙個快取）
bin/zookeeper-server-start.sh config/zookeeper.properties
*發布和訂閱通過zk實現，kafka設計就使用了zk
bin/kafka-server-start.sh conf/server.properties
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mykafka
bin/kafka-topics.sh --list --zookeeper localhost:2181
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mykafka --from-beginning
broker.id 唯一，數字
host.name 唯一，填伺服器
zookeeper.connect=hadoop110:2181,hadoop111:2181...
修改相應的broker.id host.name
啟動方式和偽分布一樣，簡單操作如上
整個架構引入佇列系統的原因：
1、為了緩解web伺服器端的處理壓力，我們需要乙個佇列系統來緩衝客戶端傳送過來的訊息，以供後續程式處理。
2、為了同時支援訊息的實時處理和持久化儲存，我們需要乙個佇列系統來做訊息分發。
搭建kafka環境
步驟2 啟動zookeeper bin zookeeper server start.sh config zookeeper.properties步驟3 修改配置檔案config server.properties，新增如下內容 host.name localhost advertised.host...
kafka環境搭建
1.拉取映象 docker pull kafkamanager kafka manager2.啟動映象 ezk hosts 1.2.3.4 宿主機ip 9000 預設埠 4.解決yikes ask timed out on actorselection anchor akka kafka manag...
kafka 單機環境kafka搭建
目錄 一 kafka搭建方法 二 kafka常用命令行 1.topic建立 2.命令列生產者 3.命令列消費者 step1 解壓kafka tar zxvf kafka 2.13 2.4.0.tgzstep2 啟動zookeeper bin zookeeper server start.sh con...