啟動建立主題
模擬生產者和消費者
一部已經安裝好的zookeeper虛擬機器
上傳kafka安裝包
為了方便執行，配置一下環境變數
export kafka_home=/opt/software/kafka/kafka_2.12-1.1.0
export path=$path:$kafka_home/bin
scp -r /opt/software/kafka root@centos163:/opt/software/
scp -r /etc/profile root@centos163:/etc/
修改一下broker.id
和host.name
先啟動zookeeper
zkserver.sh start
再啟動kafka
kafka-server-start.sh -daemon /opt/software/kafka/kafka_2.12-1.1.0/config/server.properties &
kafka-topics.sh --create --zookeeper centos161:2181,centos162:2181,centos163:2181 --replication-factor 3 --partitions 3 --topic test
引數1：server.properties中配置的引數
引數2：主題的副本數
引數3：主題內容的分割槽
引數4：主題名稱
生產者命令：
kafka-console-producer.sh --broker-list centos161:9092,centos162:9092,centos163:9092 --topic test
引數一：kafka所在的機器
引數二：主題名稱
消費者命令：
kafka-console-consumer.sh --bootstrap-server centos162:9092,centos163:9092 --from-beginning --topic test
引數一：消費者所在的機器
引數二：主題名稱
kafka安裝和基本使用
2.將檔案解壓 3.進入 kafka 2.9.2 0.8.1.1 config 目錄 4.修改 server.properties檔案 引數 參考引數值 broker.id 0 port 9092 log.dirs kafka 2.9.2 0.8.1.1 logs zookeeper.connect...
Kafka安裝和簡單使用
首先安裝zookeeper和scala 安裝zookeeper root hadoop001 conf cp zoo sample.cfg zoo.cfg root hadoop001 conf vi zoo.cfg the number of milliseconds of each tick t...
kafka安裝使用
先來說下kafka是個什麼東西，它是乙個訊息中介軟體框架，只負責發布 訂閱 幫忙存東西的 接著給大家看一張大致的kafka流程圖 首先打個比方，kafka好比就是 電視台，而 電視台下面有很多節目，生產者就是製作節目的團隊，而消費者就是我們 這個節目的人，一開始 電視台建立乙個節目，假設就叫cctv...