1.配置java運(yùn)行環(huán)境
a.查看是否已經(jīng)安裝java環(huán)境:
yum list installed |grep java
b.移除java運(yùn)行環(huán)境:
卸載JDK相關(guān)文件輸入：yum -y remove java-1.7.0-openjdk*
卸載tzdata-java輸入：yum -y remove tzdata-java.noarch歇父。
c.查看yun庫(kù)內(nèi)的java包
yum -y list java*
d.安裝java
yum -y install java-1.8.0-openjdk*
e.查看java版本
java -version
2.安裝kafka
http://kafka.apache.org/documentation.html#quickstart
按照官方的來(lái)邢锯。
tar -xzf kafka_2.11-1.0.0.tgz
cd kafka_2.11-1.0.0
需要啟動(dòng)zookeeper服務(wù)：
bin/zookeeper-server-start.sh config/zookeeper.properties &
啟動(dòng)kafka：
bin/kafka-server-start.sh config/server.properties &
驗(yàn)證:
jps
3.概念
a.kafka是什么？
記住幾個(gè)關(guān)鍵點(diǎn)，分布式、高吞吐量 的 訂閱、發(fā)布 消息系統(tǒng)
b.kafka有什么？
producer 消息的生成者，即發(fā)布消息
consumer 消息的消費(fèi)者状飞，即訂閱消息
broker Kafka以集群的方式運(yùn)行，可以由一個(gè)或多個(gè)服務(wù)組成，服務(wù)即broker
zookeeper 協(xié)調(diào)轉(zhuǎn)發(fā)
c.kafka的工作圖
圖片.png
producers通過(guò)網(wǎng)絡(luò)將消息發(fā)送到Kafka集群昔瞧，集群向消費(fèi)者提供消息指蚁。
kafka對(duì)消息進(jìn)行歸納，即topic自晰，也就是說(shuō)producer發(fā)布topic,consumer訂閱topic
