kafka+zookeeper環境配置（linux環境單機版）
阿新 • • 發佈：2017-12-14
producer lai ror detail gin prop tex wget start
版本：
CentOS-6.5-x86_64
zookeeper-3.4.6
kafka_2.10-0.10.1.0
一.zookeeper下載與安裝
1）下載
$ wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
2）解壓
tar zxvf zookeeper-3.4.6.tar.gz
3）配置
cd zookeeper-3.4.6
cp -rf conf/zoo_sample.cfg conf/zoo.cfg
vim zoo.cfg
zoo.cfg:
dataDir=/opt/zookeeper-3.4.6/zkdata #這個目錄是預先創建的
dataLogDir=/opt/zookeeper-3.4.6/zkdatalog #這個目錄是預先創建的
請參考zookeeper
4）配置環境變量
ZOOKEEPER_HOME=/opt/zookeeper-3.4.6
PATH=$JAVA_HOME/bin:$ZOOKEEPER_HOME/bin:$PATH
CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$ZOOKEEPER_HOME/lib:
5）啟動zookeeper
$ sh zkServer.sh start
二.下載並且安裝kafka
1).下載kafka:
wget http://apache.fayea.com/kafka/0.10.0.1/kafka_2.10-0.10.0.1.tgz
2) 解壓：
tar -zxvf kafka_2.10-0.10.0.1.tgz
3) 配置：
進入kafka安裝工程根目錄編輯config/server.propertiesserver.properties配置屬性說明
log.dirs=/opt/kafka_2.10-0.10.1.0/kafka_log(提前創建)
listeners=PLAINTEXT://kafka所在機器ip地址:9092
（我這裏使用的是本地 localhost）
4）啟動kafka
$ sh bin/kafka-server-start.sh config/server.properties &
#這裏我老顯示啟動報錯。
把 kafka_2.10-0.10.1.0 /config/ server.properties裏broker.id=0修改 broker.id=1
啟動成功
備註：掛到後臺使用
檢測2181與9092端口 netstat -tunlp|egrep "(2181|9092)"
5)新建一個TOPIC
$ sh kafka-topics.sh --create --topic kafkatopic --replication-factor 1 --partitions 1 --zookeeper localhost:2181
$ ./kafka-topics.sh --list --zookeeper 192.168.61.135:2181 --查看所有topic
$ ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic logTopic100 --查看指定topic
6) 把KAFKA的生產者啟動起來：
$ sh kafka-console-producer.sh --broker-list localhost:9092 --sync --topic kafkatopic
7）另開一個終端，把消費者啟動起來：
$ sh kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning
(--from beginning 是從頭開始消費，不加則是消費當前正在發送到該topic的消息)
8）使用
在發送消息的終端輸入aaa，則可以在消費消息的終端顯示
kafka+zookeeper環境配置（linux環境單機版）