简介：Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎，web/nginx日志、访问日志，消息服务等等，用scala语言编写，Linkedin于2010年贡献给了Apache基金会并成为顶级开源 项目。
1、安装jdk1.8
yum search java|grep jdk yum install java-1.8.0-openjdk* -y
2、配置环境变量
vim /etc/profile export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.181-3.b13.el6_10.x86_64 export PATH=$JAVA_HOME/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar source /etc/profile
3、下载kafka
wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz tar -zxvf kafka_2.12-2.0.0.tgz
4、修改server.properties
broker.id=0 port=9092 host.name=192.168.10.115 log.dirs=/webapps/kafka-logs zookeeper.connect=192.168.10.115:2181
5、修改zookeeper.properties
dataDir=/webapps/zookeeper tickTime=2000 initLimit=10 syncLimit=5 server.0=192.168.10.115:2181:9092
6、启动
启动zookeeper： ./zookeeper-server-start.sh ../config/zookeeper.properties 启动kafka：./kafka-server-start.sh ../config/server.properties
