集群部署（單機多點broker）：
1.將conf目錄下的配置檔案複製兩份。使用server-1 server-2 server-3進行集群。
修改server-1 server-2 server-3的配置檔案
vim config/server-1.properties
#修改內容
broker.id=1
listeners=plaintext://localhost:9092
log.dirs=/data/kafka-logs-1
vim config/server-2.properties
#修改內容
broker.id=2
listeners=plaintext://localhost:9093
log.dirs=/data/kafka-logs-2
vim config/server-3.properties
#修改內容
broker.id=3
listeners=plaintext://localhost:9094
log.dirs=/data/kafka-logs-3
3.建立測試訊息
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic test1
factor：指的使我們副本的數量，對應三個broker
檢視topic使用：./kafka-topics.sh --list --zookeeper localhost:2181
檢視詳細資訊：./kafka-topics.sh --describe --zookeeper localhost:2181 ,此時的leader:主的broker ，replicas:代表副本對應的broker id 號, isr:代表活著的broker
4.建立訊息生產者
命令：./kafka-console-producer.sh --broker-list localhost:9092,localhost:9093,localhost:9094 --topic test1
5.建立訊息消費者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytest1 --from-beginning
centos7單機安裝kafka
基礎要求作業系統 centos 7x 64位 kafka版本 kafka 2.11 0.8.2.1 提取碼 ns3c 1 關閉selinux 開放防火牆9092埠 root wzy x vi etc selinux config root wzy x tail 2 etc selinux confi...
在CentOS 7上安裝Kafka集群
一 安裝準備 1 修改系統配置 關閉selinux firewall 修改 etc security limits.conf新增以下內容 三 測試 1 在任意機器上建乙個topic，因為有三個kafka服務，所以這裡replication factor設為3 kafka topics.sh crea...
CentOS 7下安裝Kafka單機版
啟動kafka服務 kafka server start.sh config server.properties ps ef grep kafka檢視，觀察到zookeeper和kafka服務已啟動 建立乙個叫 test1234 的topic，它只有乙個分割槽，乙個副本 kafka topics.s...