- 下載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之前的版本這時(shí)就要安裝相應(yīng)的包之類的，0.8.1之后就不用了。把命令加進(jìn)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
- 制作啟動(dòng)命令，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
#方便查L(zhǎng)OG
dataLogDir=$ZOOKEEPER_HOME/logs
#控制客戶的連接數(shù)，默認(rèn)數(shù)為60，太少
maxClientCnxns=300
#如果有多個(gè)ZOOKEEPER INSTANCE時(shí)
server.1=10.120.151.223:2888:3888
server.2=10.120.151.224:2888:3888
- 啟動(dòng)ZOOKEEPER
zkServer.sh start
- 更改KAFKA的配置文件server.properties， 主要改幾個(gè)地方
#這個(gè)是配置PRODUCER/CONSUMER連上來(lái)的時(shí)候使用的地址
advertised.host.name=54.72.4.92
#設(shè)置KAFKA LOG路徑
log.dirs=$KAFKA_HOME/logs/kafka-logs
#設(shè)置ZOOKEEPER的連接地址
zookeeper.connect=54.72.4.92:2181
- 啟動(dòng)KAFKA
start-kafka.sh
- 新建一個(gè)TOPIC
#KAFKA有幾個(gè)，replication-factor就填幾個(gè)
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
- 另開(kāi)一個(gè)終端，顯示消息的消費(fèi)
kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning
- 在發(fā)送消息的終端輸入aaa，則可以在消費(fèi)消息的終端顯示