环境说明:java
详细说明(如下全部操做均是在root用户下操做):web
1、jdk安装apache
jdk分为如下几种:jre、openjdk、 oracle jdk,这里咱们要安装的是oracle jdk(推荐安装)oracle
add-apt-repository ppa:webupd8team/java apt-get update apt-get install oracle-java8-installer apt-get install oracle-java8-set-default
测试安装版本:测试
2、安装配置zookeeper单机模式spa
下载zookeeper 3.4.5,开始安装:日志
cd /usr/local wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.5/zookeeper-3.4.5.tar.gz
等待安装成功:server
解压:blog
tar -zxvf zookeeper-3.4.9.tar.gz
解压后同目录下便存在相同文件夹:ip
切换到conf目录下:
cd zookeeper-3.4.9/conf/
复制zoo_sample.cfg到zoo.cfg:
cp zoo_sample.cfg zoo.cfg
而后编辑zoo.cfg以下(其它不用管,默认便可):
initLimit=10 syncLimit=5 dataDir=/home/young/zookeeper/data clientPort=2181
别忘了新建dataDir目录:
mkdir /home/young/zookeeper/data
为zookeeper建立环境变量,打开/etc/profile文件,并在最末尾添加以下内容:
vi /etc/profile
添加内容以下:
export ZOOKEEPER_HOME=/home/young/zookeeper export PATH=.:$ZOOKEEPER_HOME/bin:$JAVA_HOME/bin:$PATH
配置完成以后,切换到zookeeper/bin目录下,启动服务:
关闭服务:
这里暂时先关闭zookeeper服务,防止下面使用kafka启动时报端口占用错误。
3、安装配置kafka单机模式
下载kafka:
cd /usr/local wget https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.0/kafka_2.11-0.11.0.0.tgz
解压:
tar -zxvf kafka_2.11-0.11.0.0.tgz
进入kafka/config目录下:
以上文件是须要修改的文件,下面一个个修改配置:
配置server.properties:
如下为修改的,其余为默认便可:
#broker.id需改为正整数,单机为1就好 broker.id=1 #指定端口号 port=9092 #localhost这一项还有其余要修改,详细见下面说明 host.name=localhost #指定kafka的日志目录 log.dirs=/usr/local/kafka_2.11-0.11.0.0/kafka-logs #链接zookeeper配置项,这里指定的是单机,因此只须要配置localhost,如果实际生产环境,须要在这里添加其余ip地址和端口号 zookeeper.connect=localhost:2181
配置zookeeper.properties:
#数据目录 dataDir=/usr/local/kafka_2.11-0.11.0.0/zookeeper/data #客户端端口 clientPort=2181 host.name=localhost
配置producer.properties:
zookeeper.connect=localhost:2181
配置consumer.properties:
zookeeper.connect=localhost:2181
最后还须要拷贝几个jar文件到kafka的libs目录,分别是zookeeper-xxxx.jar、log4j-xxxx.jar、slf4j-simple-xxxx.jar,最后以下:
4、kafka的使用
启动zookeeper服务:
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个窗口启动kafka服务:
bin/kafka-server-start.sh config/server.properties
至此单机服务搭建已经所有完成。。。