楔子

kafka簡單學習 基於kafka_2.10-0.8.2.2.tgz

搭建

基於3臺虛擬機器had2,had3,had4 上面均有zookeeper

server.properties配置下面3個屬性

broker.id=0# 三臺機器依次是 0 1 2 
log.dirs=/opt/kafka210/date/kafka-logs
zookeeper.connect=had2:2181,had3:2181,had4:2181

啟動
在 kafka目錄下建立了 start.sh指令碼(內容如下) 啟動

#!/bin/bash
nohup bin/kafka-server-start.sh config/server.properties 1>
 
/dev/null 2>&1 &

nohub 的相關資訊參考次處

控制檯命令

#1 建立topic
bin/kafka-topics.sh --create --zookeeper had2,had3,had4:2181  --replication-factor 1 --partitions 1 --topic test

#2 檢視現有的topic
bin/kafka-topics.sh --list --zookeeper had2,had3,had4:2181

# 3 啟動控制檯生產者 消費者
bin/kafka-console-producer.sh --broker-list had2:9092,had2:9092,had4:9092 --topic test
bin/kafka-console-consumer.sh  --zookeeper had2,had3,had4:2181 --topic test --from-beginning


 

官網參考