基于Scala 2.11\kafka版本:0.10.0.1
下载地址:
http://mirror.bit.edu.cn/apache/zookeeper/current/
Scala:
http://www.scala-lang.org/download/2.11.8.html
Kafka:
http://kafka.apache.org/downloads
1、Zookeeper部署
1.1、解压
[root@hadoop001 software]# tar -zxvf zookeeper-3.4.10.tar.gz
1.2、 建立软连接
[root@hadoop001 software]# ln -s zookeeper-3.4.10 zookeeper
1.3、添加环境变量
export ZK_HOME=/opt/software/zookeeper export PATH=${ZK_HOME}/bin:${PATH}
1.4、修改配置
zoo.cfg dataDir=/opt/software/zookeeper/data server.1=hadoop001:2888:3888
[root@hadoop001 conf]# mkdir /opt/software/zookeeper/data [root@hadoop001 conf]# echo 1 > /opt/software/zookeeper/data/myid
1.5、启动ZK
[root@hadoop001 zookeeper]# zkServer.sh start ZooKeeper JMX enabled by default Using config: /opt/software/zookeeper/bin/../conf/zoo.cfg
1.6、查看Zookeeper状态
[root@hadoop001 zookeeper]# zkServer.sh status ZooKeeper JMX enabled by default Using config: /opt/software/zookeeper/bin/../conf/zoo.cfg Mode: standalone
2、Kafka部署
2.1、解压
[root@hadoop001 software]# tar -xzvf kafka_2.11-0.10.0.1.tgz
2.2、建立软连接
ln -s kafka_2.11-0.10.0.1 kafka
2.3、配置环境变量
export KAFKA_HOME=/opt/software/kafka export PATH=${KAFKA_HOME}/bin:${PATH}
2.4、创建logs目录和修改producer.properties
vi ${KAFKA_HOME}/config/producer.properties broker.id=1 port=9092 host.name=hadoop001 log.dirs=/opt/software/kafka/logs zookeeper.connect=hadoop001:2181/kafka
2.5、修改 server.properties
zookeeper.connect=hadoop001:2181/kafka
2.6、启动kafka
nohup kafka-server-start.sh config/server.properties &