CentOS 7.0 安装配置 kafka 消息队列

查询下载最新版本 kafka 

http://kafka.apache.org/downloads.html

wget http://mirror.bit.edu.cn/apache/kafka/0.8.2.0/kafka-0.8.2.0-src.tgz

tar zxvf kafka-0.8.2.0-src.tgz 

mv kafka-0.8.2.0-src /opt/local/kafka

cd /opt/local/kafka

./gradlew jar

------------------------------------------------------------------------------

提示: 

错误: 找不到或无法加载主类 org.gradle.wrapper.GradleWrapperMain

需要先安装 gradle

scala 下载地址

http://www.scala-lang.org/files/archive/scala-2.10.4.tgz

tar zxvf scala-2.10.4.tgz

mv scala-2.10.4 /usr/lib64/scala

设置环境变量 

vi /etc/profile

export SACLA_HOME=/usr/lib64/scala/

export PATH=$SACLA_HOME/bin:$PATH

etc/profile

-------------------------------------------------------------------------------

执行 gradlew jar 会下载很多响应的东西

./gradlew jarAll

----------------------------------------------------------------------

jarAll 会报错，java 版本不能为1.8 不然会报不兼容的错误，请使用1.7版本

-----------------------------------------------------------------------

./gradlew jar --stacktrace  --info --debug

创建日志目录

mkdir -p /opt/local/kafka/logs

下面 编辑配置文件

vim config/server.properties

将里面的：log.dirs=/tmp/kafka-logs

zookeeper.connect=localhost:2181

改为你自己的：log.dirs=/opt/local/kafka/logs

zookeeper.connect=172.24.0.100:2181

保存退出

启动：

nohup /opt/local/kafka/bin/zookeeper-server-start.sh /opt/local/kafka/config/zookeeper.properties &

nohup /opt/local/kafka/bin/kafka-server-start.sh /opt/local/kafka/config/server.properties &

创建主题：

/opt/local/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.20.200:2181 --replication-factor 1 --partitions 1 --topic LJ200

查看现有主题：

/opt/local/kafka/bin/kafka-topics.sh --list --zookeeper 192.168.20.200:2181

LJ200