1.配置java运行环境

a.查看是否已经安装java环境:

yum list installed |grep java

b.移除java运行环境:

卸载JDK相关文件输入：yum -y remove java-1.7.0-openjdk*
卸载tzdata-java输入：yum -y remove tzdata-java.noarch。

c.查看yun库内的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
按照官方的来。

tar -xzf kafka_2.11-1.0.0.tgz
cd kafka_2.11-1.0.0

需要启动zookeeper服务：

bin/zookeeper-server-start.sh config/zookeeper.properties &

启动kafka：

bin/kafka-server-start.sh config/server.properties &

验证:

jps

3.概念

a.kafka是什么？
记住几个关键点，分布式、高吞吐量 的 订阅、发布 消息系统
b.kafka有什么？
producer 消息的生成者，即发布消息
consumer 消息的消费者，即订阅消息
broker Kafka以集群的方式运行，可以由一个或多个服务组成，服务即broker
zookeeper 协调转发
c.kafka的工作图

图片.png

producers通过网络将消息发送到Kafka集群，集群向消费者提供消息。
kafka对消息进行归纳，即topic，也就是说producer发布topic,consumer订阅topic