[大数据]kafka_2.12-2.7.0 部署

准备：linux7.6系统，kafka_2.12-2.7.0tgz（tar包，jdk（我这里用的是291版本）

解压jdk包，设置环境变量在文件的最下面输入

 vi /etc/profile （在文件最后输入）
	export JAVA_HOME=/mnt/jdk1.8.0_291
    export JRE_HOME=${JAVA_HOME}/jre
    export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
    export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
    export PATH=$PATH:${JAVA_PATH}
source /etc/profile  #使环境变量生效
 java -version        #查看java版本

解压kafka安装包

tar -zxvf kafka_2.12-2.7.0.tgz -C /usr/src/
   chown -R root:root /usr/src/kafka_2.12-2.7.0/ #设置属主和属组
   cd /usr/src/kafka_2.12-2.7.0/
 cp server.properties server.properties.bak #备份配置文件

修改配置文件

 vim server.properties
	broker.id =0    每一个broker在集群中的唯一表示，要求是正数。
 	listeners=PLAINTEXT://127.0.0.1:9092  监听端口
	zookeeper.connect=127.0.0.1:2181  zook的端口
	zookeeper.connection.timeout.ms=60000  ZooKeeper的最大超时时间
vim zookeeper.properties
    clientPort=2181 #监听端口

运行kafka，以守护进程的方式启动

 ./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties 
 ps -ef | grep zookeeper
 ./bin/kafka-server-start.sh  -daemon ./config/server.properties