ToB企服应用市场:ToB评测及商务社交产业平台

标题: linux系统安装kafka（新版本3.7.0） [打印本页]
作者: 怀念夏天    时间: 2024-6-19 00:41
标题: linux系统安装kafka（新版本3.7.0）
1、安装包下载

  1. wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
复制代码
注意事项：kafka会用到jdk，kafka_2.13-3.7.0版本的kafka不再支持jdk8，我这里用的jdk11
openjdk11下载1：https://mirrors.tuna.tsinghua.edu.cn/Adoptium/11/jdk/x64/linux/
openjdk11下载2：https://learn.microsoft.com/zh-cn/java/openjdk/download
我的解压目次/usr/local/jdk-11.0.23+9
2、安装

  1. 我安装到 /usr/local目录下了
  2. cs /usr/local
  3. #解压
  4. tar -xzf kafka_2.13-3.7.0.tgz
  5. cd kafka_2.13-3.7.0
复制代码
首先要启动ZooKeeper服务，因为Kafka使用ZooKeeper，新版本中kafka集成了zookeeper
3、配置zookeeper.properties

配置kafka_2.13-3.7.0/config下的“zookeeper.properties”：
修改dataDir和clientPort：前者是快照存放地址(自己随意配置)，后者是客户端毗连zookeeper服务的端口。默认端口2181
  1. #创建一个目录
  2. mkdir zookeeper-data
  3. #修改文件路径为：
  4. dataDir=/usr/local/kafka_2.13-3.7.0/zookeeper-data
复制代码
截图如下：

4、配置server.properties

配置kafka_2.13-3.7.0/config下的“server.properties”：
修改log.dirs和zookeeper.connect。前者是日记存放文件夹，后者是zookeeper毗连地址（端口和clientPort保持同等）
  1. 创建一个目录：
  2. mkdir kafka-logs
  4. 修改配置：
  5. #日志目录
  6. log.dirs=/usr/local/kafka_2.13-3.7.0/kafka-logs
  7. #zookeeper连接地址
  8. zookeeper.connect=localhost:2181
复制代码
注意：若需要外部访问，一定需要配置listeners ， 默认为本机IP 、端口默认9092。
截图：


5、启动

由于我的服务器有其他程序用jdk8，并配置了环境变量，所以在启动之前，我要修改脚本中使用jdk的路径：
修改：kafka-run-class.sh
在文件开始位置指定JAVA_HOME位置，文件中会用到
  1. export JAVA_HOME=/usr/local/jdk-11.0.23+9
复制代码
截图：

  1. # 后台启动zookeeper，指定启动日志
  2. nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties > ./zookeeper-run.log 2>&1 &
复制代码
  1. # 后台启动kafka，指定启动日志
  2. nohup ./bin/kafka-server-start.sh ./config/server.properties > ./kafka-run.log 2>&1 &
复制代码
现在，Kafka单机版已经安装并运行。你可以使用内置的命令行工具来创建主题、生产消息和消费消息。
6、测试使用

创建主题：
  1. bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
复制代码
生产消息：
  1. bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
复制代码
消费消息
  1. bin/kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092 --from-beginning
复制代码
以上步调在一台机器上完成了Kafka的根本安装和运行。如果你需要在生产环境中使用Kafka，你可能需要考虑配置Kafka集群大概使用更高级的管理和监控工具。
7、克制服务

先克制kafka
  1. bin/kafka-server-stop.sh
复制代码
再克制zookeeper：
  1. bin/zookeeper-server-stop.sh  
复制代码
8、报错解决


配置文件中配置监听
  1. listeners = PLAINTEXT://服务器ip:9092
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4