1、下载kafka安装包
http://kafka.apache.org/
kafka_2.10-0.9.0.0.tgz(这里以kafka_2.10-0.9.0.0.tgz为例,单机配置,分布是后面会说到)
2、解压
tar -xvf kafka_2.10-0.9.0.0.tgz
3、添加kafka环境变量
vim /etc/profile
#kafka环境变量
export KAFKA_HOME=/root/kafka
export PATH=$PATH:$KAFKA_HOME/bin
4、启动单机模式
修改配置文件
cd /root/kafka/config
vim server.properties
broker.id=0 //为依次增长的:0、1、2、3、4,集群中唯一id
log.dirs=/root/kafka/logs //日志地址
zookeeper.connect=master:2181,slave1:2181,slave2:2181 //zookeeperServers列表,各节点以逗号分开
(这里使用单节点,zookeeper.connect=localhost:2181)
启动kafka,但先要确保zookeeper启动
nohup bin/kafka-server-start.sh config/server.properties &
nohup &:实现在后台启动
# netstat -tunlp|egrep "(2181|9092)"
tcp 0 0 :::9092 :::* LISTEN 57688/java
tcp 0 0 :::2181 :::* LISTEN 57246/java
5、简单测试
启动producer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动consumer
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning