Ubuntu 16下單機安裝配置zookeeper和kafka

環境說明:java

  • os:Ubuntu 16.04
  • zookeeper:zookeeper 3.4.9
  • kafka:kafka_2.11-0.11.0.0
  • jdk:jdk 8(kafka啓動須要使用到jdk)

詳細說明(如下全部操做均是在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

 

至此單機服務搭建已經所有完成。。。

相關文章
相關標籤/搜索