centos7 下搭建 kafka 环境_kafka-run-class.sh: line 346: exec: java: not foun

从头开始搭建一个测试环境的kafka，包含两个broker节点，一个zk节点

环境准备

1、下载卡夫卡

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

2、 下载 zookeeper

http://mirror.bit.edu.cn/apache/zookeeper/

3、下载scala

https://www.scala-lang.org/download/2.11.8.html

 配置与启动

一、配置scala

1、找到下载好的压缩包，执行命令解压

tar -zxvf  scala-2.11.8.tgz

2、配置环境变量 SCALA_HOME

cd /etc/profile.d

如果有 path.sh 文件，可以增加以下内容，没有可以创建下

export SCALA_HOME=/app/soft/scala/scala-2.11.8
export PATH=$PATH:$SCALA_HOME/bin 

 在/etc/profile.d目录下，键入source path.sh命令，使配置生效。

在控制台中键入scala -version 和 scala，看下配置是否生效

二、配置 zookeeper

1、进入下载好的压缩包目录，执行

tar –zxvf  zookeeper-3.4.14.tar.gz

 2、在zookeeper-3.4.14目录下创建两个文件夹 data，logs

3、进入conf目录，把zoo_sample.cfg文件复制一份名字改成zoo.cfg。

cp zoo_sample.cfg zoo.cfg

4、修改zoo.cfg文件，需要修改以下几个地方。

dataDir=/app/soft/zookeeper/zookeeper-3.4.14/data
dataLogDir=/app/soft/zookeeper/zookeeper-3.4.14/logs

5.配置完以后，就可以启动zookeeper服务了，进入zookeeper的bin目录，启动zookeeper服务。

./zkServer.sh start

6.启动完成后，查看服务状态。

./zkServer.sh status

 三、配置kafka

1、进入kafka目录，执行解压命令

tar -zxvf kafka_2.11-2.3.0.tgz

2、进入配置目录 

cd ./kafka_2.11-2.3.0/config 

3、如果我们想启动两个服务，可以使用

cp server.properties server1.properties

cp server.properties server2.properties 

4\、修改两个文件的 broker.id      listeners log.dirs        zookeeper.connect,，其他选项可以根据需要修改

注意：log.dirs 这个需要改一下，别放在tmp 目录下 可能运行一段时间就被删除掉了

1. broker.id=0
2. listeners=PLAINTEXT://xx.xx.xx.xx:9092
3. log.dirs=/app/soft/kafka-logs1
4. zookeeper.connect=localhost:2181

保证两个配置文件的前三项不一样 

5、在bin目录下创建启动脚本启动 run.sh

./kafka-server-start.sh ../config/server1.properties
./kafka-server-start.sh ../config/server2.properties

在后台启动即可

nohup sh run.sh & 

可能会遇到的问题

1、jdk 不兼容：这个需要使用 jdk8 以上，如果我们的java_home 是8以下的，可以通过以下方式修改

进入kafka的bin目录  修改 kafka-run-class.sh 里面的 java_home,把红框里面的改为 jdk8目录即可