上传jdk tar包 解压
# tar -zxvf jdk-11.0.13_linux-x64_bin.tar.gz
配置环境变量(注意JAVA_HOME的路径为解压路径)
#set java envirinment JAVA_HOME=/usr/local/software/jdk-11.0.13 CLASSPATH=$JAVA_HOME/lib/ PATH=$PATH:$JAVA_HOME/bin export PATH JAVA_HOME CLASSPATH
让配置生效:
# source /etc/profile
然后查看是否配置成功
# java -version2.下载安装运行kafka(注意不要下载成源码包)
解压压缩包
# tar -zxvf kafka_2.13-3.0.0.tgz
修改配置文件
进入config文件夹下的 server.properties
# 每台kafka服务器的id broker.id=0 # 连接到当前这台kafka的地址 listeners=PLAINTEXT://localhost:9092 # 日志存放的路径 log.dirs=/tmp/kafka-logs # zookeeper地址 zookeeper.connect=localhost:2181
然后启动kafka
#启动zookerrper -daemon守护进程 $ bin/zookeeper-server-start.sh -daemon config/zookeeper.properties #启动kafka $ bin/kafka-server-start.sh config/server.properties # 查看是否启动 --查看是否有进程关联到server.properties ps -aux | grep server.propertieskafka中文文档:
https://kafka.apachecn.org/documentation.html#producerconfigs
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)