前言

storm和kafka集群安裝是沒(méi)有必然聯(lián)系的，我將這兩個(gè)寫在一起，是因?yàn)樗麄兌际怯蓏ookeeper進(jìn)行管理的，也都依賴于JDK的環(huán)境，為了不重復(fù)再寫一遍配置，所以我將這兩個(gè)寫在一起。若只需一個(gè)，只需挑選自己選擇的閱讀即可。

灌南網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián),灌南網(wǎng)站設(shè)計(jì)制作，有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為灌南上1000家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站制作要多少錢，請(qǐng)找那個(gè)售后服務(wù)好的灌南做網(wǎng)站的公司定做！

這兩者的依賴如下:

• Storm集群：JDK1.8 , Zookeeper3.4，Storm1.1.1；
• Kafa集群: JDK1.8 ，Zookeeper3.4 ，Kafka2.12；

說(shuō)明: Storm1.0 和Kafka2.0對(duì)JDK要求是1.7以上，Zookeeper3.0以上。

下載地址:
Zookeeper：https://zookeeper.apache.org/releases.html#download
Storm: http://storm.apache.org/downloads.html
Kafka: http://kafka.apache.org/downloads

JDK安裝

每臺(tái)機(jī)器都要安裝JDK！?。?/strong>
說(shuō)明: 一般CentOS自帶了openjdk，但是我們這里使用的是oracle的JDK。所以要寫卸載openjdk，然后再安裝在oracle下載好的JDK。如果已經(jīng)卸載，可以跳過(guò)此步驟。
首先輸入 java -version
查看是否安裝了JDK，如果安裝了，但版本不適合的話，就卸載

可以使用進(jìn)行Ctrl+C 退出

可以看到數(shù)據(jù)已經(jīng)正常消費(fèi)了。

5，kafka的一些常用命令

1.啟動(dòng)和關(guān)閉kafka

bin/kafka-server-start.sh config/server.properties >>/dev/null 2>&1 &
bin/kafka-server-stop.sh

2.查看kafka集群中的消息隊(duì)列和具體隊(duì)列
查看集群所有的topic

 kafka-topics.sh --zookeeper master:2181,slave1:2181,slave2:2181 --list

查看一個(gè)topic的信息

 kafka-topics.sh --zookeeper master:2181 --describe --topic t_test  

3.創(chuàng)建Topic

kafka-topics.sh --zookeeper master:2181 --create --topic t_test --partitions 5  --replication-factor 2

4.生產(chǎn)數(shù)據(jù)和消費(fèi)數(shù)據(jù)

kafka-console-producer.sh --broker-list master:9092 --topic t_test

Ctrl+D 退出

kafka-console-consumer.sh  --zookeeper master:2181  --topic t_test --from-beginning

Ctrl+C 退出

5.kafka的刪除命令

kafka-topics.sh --delete --zookeeper master:2181 --topic t_test

6,添加分區(qū)

kafka-topics.sh --alter --topict_test --zookeeper master:2181 --partitions 10