消息队列 kafka在linux下的安装
检验java -version 是否可以运行，如果不能，请安装java jdk
在安装kafka的时候，确定服务器中一定要存在java的jdk 否则不能安装。
先安装 java jdk
首先通过 uname -a 看看系统是32位的 还是64位的
[root@localhost kafka]# uname -a
Linux localhost.localdomain 2.6.32-431.el6.i686 #1 SMP Fri Nov 22 00:26:36 UTC 2013 i686 i686 i386 GNU/Linux
如果输出结果中含有X86_64，表明系统是64位的，如果出现i686，证明系统是32位的。
我的系统是32位的。
下载jdk包：
打开网站：
http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
找到
如果系统是 64位的，下载 红框下 第二个就可以了
通过 直接点击下载到本地 ，然后上传到服务器。
或直接登录linux服务器 通过 wget 下载文件到linux服务器
解压文件：
tar -xf jdk-8u161-linux-i586.tar.gz
然后把整个文件夹 复制到 /usr/loca/jdk1.8.0_161 到这个目录 。我安装的文件都在这个目录中
配置环境变量：
打开 /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_161 export PATH=$JAVA_HOME/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
设置好以后保存退出
立即生效：
source /etc/profile
测试 java 是否生效：
java -version
安装kafka
首先打开网站：http://kafka.apache.org/downloads
我们选择最新版的 二级制包
好的，到这里下载完成
1、解压
tar -xf kafka_2.11-1.0.0.tgz
2、进入目录
这是kafka解压后的文件列表
默认我们把 软件都安装在/usr/local/下，
那么我们把 整个目录 剪切 到 /usr/local/kafka
mv kafka_2.11-1.0.0 /usr/local/kafka
3、修改配置
打开config文件夹
配置 zookeeper.properties 默认不用配置什么
配置 server.properties
开启监听本机端口
5、启动程序
首先启动 zookeeper 然后启动kafka
zookeeper启动
bin/zookeeper-server-start.sh config/zookeeper.properties
server kafka 启动
bin/kafka-server-start.sh config/server.properties
以上两个服务器都启动起来了。
6、启动一个测试
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
7、启动一个消息生产者
bin/kafka-console-producer.sh --broker-list 192.168.61.103:9092 --topic test
直接回车，就发出去了一条消息
这是第三个窗口 consumer收到的信息：
这是整个程序运行的窗口示意图：
