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

news/2024/12/11 14:12:40/

前置安装

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/news/1554235.html

相关文章

vue3-canvas实现在图片上框选标记(放大,缩小,移动,删除)

双图版本(模板对比) 业务描述:模板与图片对比,只操作模板框选的位置进行色差对比,传框选坐标位置给后端,返回对比结果显示 draw.js文件: 新增了 createUuid,和求取两个数组差集的方…

开发类似的同款小程序系统制作流程

很多老板想要开发一款和别人家类似的同款小程序系统,但是不知道该怎么开发制作,本文就为大家详细介绍一下开发类似的同款小程序的流程为大家做参考。 一、前期准备找到对标小程序:首先,需要找到你想要模仿的同款小程序&#xff0…

Flink中常用物理分区(区别和用法)算子以及Sink(JDBC Connector、Kafka Connector以及自定义Sink)

文章目录 一、物理分区1、自定义分区重分区(解决数据倾斜) 二、Sink1、JDBC Connector(JDBC连接器)2、Kafka Connector(Kafka连接器)3、自定义Sink 一、物理分区 1、自定义分区重分区(解决数据倾…

艺诚美业管理系统

摘 要 21世纪的今天,随着社会的不断发展与进步,人们对于信息科学化的认识,已由低层次向高层次发展,由原来的感性认识向理性认识提高,管理工作的重要性已逐渐被人们所认识,科学化的管理,使信息存…

DevExpress WPF v24.2新功能预览 - 键盘导航和屏幕阅读器功能增强

DevExpress WPF拥有120个控件和库,将帮助您交付满足甚至超出企业需求的高性能业务应用程序。通过DevExpress WPF能创建有着强大互动功能的XAML基础应用程序,这些应用程序专注于当代客户的需求和构建未来新一代支持触摸的解决方案。 无论是Office办公软件…

三菱FX3uPLC输入接线注意事项

FX3u微型控制器(DC输入型)的输入根据外部接线,漏型输入和源型输入都可使用。 但是,一定要连接S/S端子的接线。 详细事宜请参考“FX3U系列微型控制器硬件说明手册 AC电源型的输入接线事例(FX3U-囗MR/UA1除外) DC电源型的输入接线事例 *请不要与(0V)、(24V)端子接线…

前端的 Python 入门指南(四):参数传递方式对比 - 值与引用传递 vs 可变不可变数据的优劣分析+副作用分析

《前端的 Python 入门指南》系列文章: (一):常用语法和关键字对比(二):函数的定义、参数、作用域对比(三):数据类型对比 - 彻底的一切皆对象实现和包装对象异…

android 常用三方框架

说实话, 我是比较讨厌三方框架的, 比如一个eventbus 底层逻辑就是个观察者模式,当然他的场景涵盖的比较丰富, 单从 单一原则来说, 还是一个简单的观察者模式就能解决问题, 何必要添加那么多文件到我们的项目…