環境說明: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
至此單機服務搭建已經所有完成。。。