【kafka】kafka安装(ubuntu+jdk+zookeeper)

ops/2024/12/18 2:51:28/

前置安装

1.jdk安装与环境变量配置

  • 安装 OpenJDK 21或者其他版本
sudo apt update
sudo apt install openjdk-21-jdk
  • 使用 readlink 命令查找 java 的路径
readlink -f $(which java)

在这里插入图片描述
复制

  • 永久设置JAVA_HOME
# 粘贴路径/usr/lib/jvm/java-21-openjdk-amd64  
echo "export JAVA_HOME=/usr/lib/jvm/java-21-openjdk-amd64" >> ~/.bashrc
  • 配置生效
source ~/.bashrc
  • 检查环境变量是否配置成功
java -version
echo $JAVA_HOME

2.zookeeper安装

Zookeeper 是一个分布式协调服务,广泛用于分布式系统中,以确保系统中的各个组件能够进行有效的协调、同步和管理。Kafka 就是依赖 Zookeeper 来管理集群状态、控制分区分配等工作。

  • 通过阿里镜像下载Apache Zookeeper
    这里下载zookeeper3.8.4
    阿里镜像
// 临时禁用代理并下载
http_proxy="" https_proxy="" wget https://mirrors.aliyun.com/apache/zookeeper/zookeeper-3.8.4/apache-zookeeper-3.8.4-bin.tar.gz
  • 解压
tar -xvzf apache-zookeeper-3.8.4-bin.tar.gz
  • 配置 Zookeeper,进入解压后的目录,进入 conf 目录并复制 zoo_sample.cfg 文件为 zoo.cfg 文件
cd apache-zookeeper-3.8.4-bin/conf
cp zoo_sample.cfg zoo.cfg
  • 编辑 zoo.cfg 配置文件
sudo vim zoo.cfg
  • 确认一下信息
# 数据存储目录
dataDir=/var/lib/zookeeper
# 客户端连接端口
clientPort=2181
# 服务器集群的ID(默认是一个服务器,可以不改)
tickTime=2000
initLimit=10
syncLimit=5
  • 创建数据存储目录
sudo mkdir -p /var/lib/zookeeper
// 赋予写入权限 用户名:用户组名,一般相同
sudo chown -R chenaws:chenaws /var/lib/zookeeper
  • 启动 Zookeeper,
    配置完成后,返回到 Zookeeper 根目录,启动 Zookeeper 服务器
cd ~/apache-zookeeper-3.8.4-bin      
bin/zkServer.sh start      

成功!!!
在这里插入图片描述

  • 如果想要停止Zookeeper
bin/zkServer.sh stop    

kafka_86">正式安装配置kafka

先建个文件夹

chenaws@chenaws-VMware-Virtual-Platform:~/kafka$ pwd
/home/chenaws/kafka
  • kafka文件夹下再建个data文件夹
mkdir data
  • 使用镜像下载二进制编译文件 kafka-3.9.0
    kafka镜像地址
curl -O https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/3.9.0/kafka_2.12-3.9.0.tgz
  • 解压
tar -xzvf kafka_2.12-3.9.0.tgz
  • 验证解压成功
cd /home/itheima/kafka/kafka_2.12-3.9.0
bin/kafka-topics.sh --version

在这里插入图片描述

修改配置文件

sudo vim config/server.properties
  • 修改一下内容
    在这里插入图片描述
    这里改成
// 你的虚拟机ip
listeners=PLAINTEXT://192.168.88.128:9092

在这里插入图片描述

这里改成刚才新建的data目录存储日志

log.dirs=/home/itheima/kafka/data

在这里插入图片描述
这里改为

// 虚拟机ip
zookeeper.connect=192.168.88.128:2181

保存退出

// 注意当前路径
bin/kafka-server-start.sh -daemon config/server.properties
  • 检查是否运行成功
ps aux | grep kafka

在这里插入图片描述

成功!


http://www.ppmy.cn/ops/142785.html

相关文章

Ubuntu系统下部署大语言模型:Ollama和OpenWebUI实现各大模型的人工智能自由

之前在window下安装过 Ollama和OpenWebUI搭建本地的人工智能web项目(可以看我之前写的文章),无奈电脑硬件配置太低,用qwen32b就很卡,卡出PPT了,于是又找了一台机器安装linux系统,在linux系统下测试一下速度能否可以快一些。 系统硬件介绍 Ubuntu 22.04.4 LTS CPU: i5…

OpenCV图片添加水印

在数字图像处理领域,为图片添加水印是一项常见的任务,它既可以用于版权保护,也可以用于品牌宣传。 图片添加水印的基本原理是将一个较小的图像(水印)嵌入到另一个较大的图像(原图)中。这个过程…

初始JavaEE篇 —— 网络原理---应用层协议:深入理解 HTTP/HTTPS

找往期文章包括但不限于本期文章中不懂的知识点: 个人主页:我要学编程程(ಥ_ಥ)-CSDN博客 所属专栏:JavaEE 我们在前面简单的接触了 TCP/IP五层协议中的传输层协议,并使用 UDP协议 与 TCP协议 编写了一个简单的回显服务器 与 客户…

uniapp打包apk允许横屏竖屏内容翻转

文章目录 一、教程总结 一、教程 1.添加配置 "orientation": [//竖屏正方向"portrait-primary",//竖屏反方向"portrait-secondary",//横屏正方向"landscape-primary",//横屏反方向"landscape-secondary",//自然方向"…

使用 mkcert 工具自签发 https 证书并进行本地受信

介绍 mkcert 是一个用于创建本地受信任的 SSL/TLS 证书的简单工具,特别适合开发者在本地环境中使用。它解决了为开发和测试目的创建自签名证书时遇到的信任问题。以下是关于 mkcert 的详细介绍: 特点 易用性:只需一条命令即可生成证书&…

Python序列的应用(八):元组、字典

前言:在Python编程语言中,序列是一种非常重要的数据结构,它允许我们存储和操作有序的数据集合。在前几期的内容中,我们已经探讨了列表(List)和集合(Set)这两种序列的应用&#xff0c…

Unreal Engine 5 (UE5) 中“变换“(Transform)类型变量

在 Unreal Engine 5 (UE5) 中,"变换"(Transform)类型变量是一个非常常见和重要的数据类型,它用于表示 对象的位置(Location)、旋转(Rotation) 和 缩放(Scale&a…

【Unity功能集】TextureShop纹理工坊(一)功能集介绍

项目源码:后期发布 免责声明:【TextureShop】使用的图片等素材均有可能来自互联网,本专栏所有文章仅做学习和教程目的,不会将任何素材用于任何商业用途。 索引 【系列简介】功能集效果介绍选定选区移动选区套索工具魔术棒工具修剪…