- 下载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
#控制客户的连接数，默认数为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
- 发送消息至KAFKA
kafka-console-producer.sh --broker-list localhost:9092 --sync --topic kafkatopic
- 另开一个终端，显示消息的消费
kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning
- 在发送消息的终端输入aaa，则可以在消费消息的终端显示