- 下載KAFKA
wget http://apache.fayea.com/apache-mirror/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz
- 解壓
tar -zxf kafka_2.9.2-0.8.1.1.tgz
- 0.7之前的版本這時就要安裝相應的包之類的，0.8.1之后就不用了。把命令加進PATH中
export KAFKA_HOME=/home/ubuntu/java/kafka_2.9.2-0.8.1.1
export PATH=$JAVA_HOME/bin:$STORM_HOME/bin:$KAFKA_HOME/bin:$ZOOKEEPER_HOME/bin:$BIN_HOME/bin:$MAVEN_HOME/bin:$PATH
- SOURCE一下
source /etc/profile
- 制作啟動命令，start-kafka.sh，并放于kafaka_hoem/bin下
kafka-server-start.sh $KAFKA_HOME/config/server.properties &
- 安裝ZOOKEEPER
wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
tar -zxf zookeeper-3.4.6.tar.gz
cd zookeeper-3.4.6.tar.gz/conf
cp zoo_sample.cfg zoo.cfg
- 改zoo.cfg
dataDir=$ZOOKEEPER_HOME/data
#方便查LOG
dataLogDir=$ZOOKEEPER_HOME/logs
#控制客戶的連接數(shù)，默認數(shù)為60，太少
maxClientCnxns=300
#如果有多個ZOOKEEPER INSTANCE時
server.1=10.120.151.223:2888:3888
server.2=10.120.151.224:2888:3888
- 啟動ZOOKEEPER
zkServer.sh start
- 更改KAFKA的配置文件server.properties， 主要改幾個地方
#這個是配置PRODUCER/CONSUMER連上來的時候使用的地址
advertised.host.name=54.72.4.92
#設置KAFKA LOG路徑
log.dirs=$KAFKA_HOME/logs/kafka-logs
#設置ZOOKEEPER的連接地址
zookeeper.connect=54.72.4.92:2181
- 啟動KAFKA
start-kafka.sh
- 新建一個TOPIC
#KAFKA有幾個，replication-factor就填幾個
kafka-topics.sh --create --topic kafkatopic --replication-factor 1 --partitions 1 --zookeeper localhost:2181
- 發(fā)送消息至KAFKA
kafka-console-producer.sh --broker-list localhost:9092 --sync --topic kafkatopic
- 另開一個終端，顯示消息的消費
kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning
- 在發(fā)送消息的終端輸入aaa，則可以在消費消息的終端顯示