linux部署kafka3.5.1(单机)

一、下载jdk17

kafka3.x版本需要jdk11以上版本才能更好的兼容,jdk11、jdk17都是LTS长期维护版本,而且jdk17支持springboot3.x,所以我选择了openjdk17。

下载地址: Archived OpenJDK GA Releaseshttps://jdk.java.net/archive/

二、上传jdk安装包解压

openjdk-17_linux-x64_bin.tar.gz 安装包上传到服务器的安装目录

执行命令解压: tar -zxvf openjdk-17_linux-x64_bin.tar.gz

三、配置jdk环境变量

由于我使用的不是root用户安装kafka的,所以我把环境变量配在~/.bashrc文件中了

vim ~/.bashrc

按 i 编辑,文件末尾追加内容如下:

export JAVA_HOME=/usr/local/jdk/jdk17

export JRE_HOME=$JAVA_HOME/jre

export CLASSPATH = .:$JAVA_HOME/lib:$JRE_HOME/lib

export PATH = $JAVA_HOME/bin:$PATH

:wq 保存退出

source ~/.bashrc 执行环境变量脚本

验证是否生效: java -version

四、下载kafka3.5.1

官方网站太卡,建议通过国内清华大学的开源软件镜像站下载。

下载路径:清华大学开源软件镜像站 | Tsinghua Open Source Mirror清华大学开源软件镜像站,致力于为国内和校内用户提供高质量的开源软件镜像、Linux 镜像源服务,帮助用户更方便地获取开源软件。本镜像站由清华大学 TUNA 协会负责运行维护。https://mirrors.tuna.tsinghua.edu.cn/

五、上传kafka安装包解压

cd /home/kafka/soft

tar -zxvf kafka_2.13-3.5.1.tgz

六、配置kafka配置文件

6.1修改kafka配置文件

vim conf/server.properties

--修改kafka的数据存储目录

log.dir=/home/kafka/soft/kafka_2.13-3.5.1/dataKafka

--内部地址

listeners=PLAINTEXT://:9092

--对外暴露地址(一般用公网地址,如果是局域网使用,也可以是内网地址)

advertised.listeners=PLAINTEXT://公网ip:9092  

6.2修改zookeeper配置文件(kafka自带zookeeper)

vim conf/zookeeper.properties

--修改zookeeper的数据存储目录

dataDir=/home/kafka/soft/kafka_2.13-3.5.1/dataZookeeper

七、启动kafka

7.1启动zookeeper

./bin/zookeeper-server.start.sh -daemon zookeeper.properties

查看启动日志 

tail -222f logs/kafkaServer.out 或 tail -222f logs/server.log

7.2启动kafka

./bin/kafka-server.start.sh -daemon server.properties

tail -222f logs/zookeeper.out

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/76745.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Netty为什么高效,为什么这么受欢迎?

文章目录 前言Netty 解决的问题简化网络编程粘包和拆包 高性能的设计多线程调度零拷贝 总结 前言 上篇文章通过 Java NIO 的处理流程与 Netty 的总体流程比较,并结合 Netty 的源码,可以更加清晰地理解Netty。本文将结合源码详细解析Netty的高效和强大功…

spring源码分析bean的生命周期(下)

doGetBean()执行过程 createBean()执行过程 一、DependsOn注解 spring创建对象之前会判断类上是否加了DependsOn注解,加了会遍历然后会添加到一个map中,spring会先创建DependsOn注解指定的类 二、spring类加载器 在合并BeanDefinition,确定…

【校招VIP】java语言类和对象之map、set集合

考点介绍: map、set集合相关内容是校招面试的高频考点之一。 map和set是一种专门用来进行搜索的容器或者数据结构,其搜索效率与其具体的实例化子类有关系。 『java语言类和对象之map、set集合』相关题目及解析内容可点击文章末尾链接查看! …

网络通信原理传输层TCP三次建立连接(第四十八课)

ACK :确认号 。 是期望收到对方的下一个报文段的数据的第1个字节的序号,即上次已成功接收到的数据字节序号加1。只有ACK标识为1,此字段有效。确认号X+1SEQ:序号字段。 TCP链接中传输的数据流中每个字节都编上一个序号。序号字段的值指的是本报文段所发送的数据的第一个字节的…

20W IP网络吸顶喇叭 POE供电吸顶喇叭

SV-29852T 20W IP网络吸顶喇叭产品简介 产品用途: ◆室内豪华型吸顶喇叭一体化网络音频解码扬声器,用于广播分区音频解码、声音还原作用 ◆应用场地如火车站、地铁、教堂、工厂、仓库、公园停车场等;室内使用效果均佳。 产品特点&#xff…

ARM体系结构学习笔记:过程调用标准AAPC、 ARM32调用约定、ARM64调用约定

参数传递的本质: 将上层函数变量复制一份, 传给下层函数. 过程调用标准AAPC(Arm Architecture Procedure Call) 有了标准, 才能够进行C调用汇编或者汇编调用C ARM32调用约定 参数是不同位数传参情况, 额外的参数被caller进行入栈, callee进行出栈 寄存器传参 寄存器返回 汇编…

OpenCV importerror:dll load failed

从预编译的二进制文件安装OpenCV,从github下载opencv-4.8.0-windows.exe 编译好的文件。按照官方文档拖入cv2.pyd文件。 https://docs.opencv.org/4.8.0/d5/de5/tutorial_py_setup_in_windows.html 使用pycharm运行时,出现报错,importerror…

leetcode做题笔记85最大矩形

给定一个仅包含 0 和 1 、大小为 rows x cols 的二维二进制矩阵,找出只包含 1 的最大矩形,并返回其面积。 示例 1: 思路一:单调栈 int maximalRectangle(char** matrix, int matrixSize, int* matrixColSize){int dp[matrixSize…

Vue项目商品购物车前端本地缓存逻辑(适用H5/ipad/PC端)——前端实现购物车删除商品、购物车增减数量,清空购物车功能

一、需求 1、用户选择商品,自动回显在购物车列表中; 2、同个商品追加,购物车列表数量叠加; 3、开启赠送,选中的商品,在购物车中另增一条数据,且购物车列表价格显示为0;其实际价格在…

16、Flink 的table api与sql之连接外部系统: 读写外部系统的连接器和格式以及FileSystem示例(1)

Flink 系列文章 1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接 13、Flink 的table api与sql的基本概念、通用api介绍及入门示例 14、Flink 的table api与sql之数据类型: 内置数据类型以及它们的属性 15、Flink 的ta…

安装docker配置镜像加速器,容器等

1.安装docker服务,配置镜像加速器 2.下载系统镜像(Ubuntu、 centos) 3.基于下载的镜像创建两个容器 (容器名一个为自己名字全拼,一个为首名字字母) 4.容器的启动、 停止及重启操作 5.怎么查看正在运行的容器…

无需公网IP——搭建web站点

文章目录 概述使用 Raspberry Pi Imager 安装 Raspberry Pi OS设置 Apache Web 服务器测试 web 站点安装静态样例站点将web站点发布到公网安装 Cpolar内网穿透cpolar进行token认证生成cpolar随机域名网址生成cpolar二级子域名将参数保存到cpolar配置文件中测试修改后配置文件配…