CentOS 7 中安装Kafka

文章目录

      • 安装JDK
        • 解压
        • 环境变量
        • 验证
      • 安装ZooKeeper
        • 下载
        • 解压
        • 环境变量
        • 配置
        • 启动
        • 开放端口
      • 安装Kafka
        • 下载
        • 解压
        • 配置
        • 启动

CentOS 7.6

JDK 1.8

ZooKeeper 3.5.7

Kafka 2.11-2.4.0

安装JDK

解压
# 解压
tar -xzvf jdk-8u181-linux-x64.tar.gz
mv jdk1.8.0_181 /usr/local/jdk1.8
环境变量
# 打开.bashrc文件
vi ~/.bashrc# 文件末尾添加如下内容
export JAVA_HOME=/usr/local/jdk1.8
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH# 输入下面的命令使之生效
source ~/.bashrc
验证

打开命令行终端,输入如下命令:

java -version

显示版本信息,说明安装成功

安装ZooKeeper

下载

点击官网下载

解压
# 解压
tar -xzvf apache-zookeeper-3.5.7-bin.tar.gz
sudo mv apache-zookeeper-3.5.7-bin /usr/local/zookeeper-3.5.7
环境变量
# 打开/etc/profile
vi /etc/profile# 添加如下内容,然后保存
export ZOOKEEPER_HOME=/usr/local/zookeeper-3.5.7
export PATH=.:$ZOOKEEPER_HOME/bin:$JAVA_HOME/bin:$PATH# 重新编译使环境变量生效
source /etc/profile
配置
# 切换到conf目录下
cd /usr/local/zookeeper-3.5.7/conf
# 复制zoo_sample.cfg到zoo.cfg
cp zoo_sample.cfg zoo.cfg
# 打开zoo.cfg
vi zoo.cfg# 修改配置如下,然后保存
# 存放数据
dataDir=/usr/local/zookeeper-3.5.7/dataDir
# 存放日志文件
dataLogDir=/usr/local/zookeeper-3.5.7/dataLogDir
# 端口默认为2181,单机版可不配置
clientPort=2181# 创建文件夹
mkdir /usr/local/zookeeper-3.5.7/dataDir
mkdir /usr/local/zookeeper-3.5.7/dataLogDir
启动
cd /usr/local/zookeeper-3.5.7/bin
# 启动命令
./zkServer.sh start
# 停止命令
./zkServer.sh stop
开放端口

如果需要允许其他机器访问,需要开放2181端口

firewall-cmd --add-port=2181/tcp --permanent
firewall-cmd --reload

安装Kafka

下载

点击官网下载

解压
# 解压
tar -zxf kafka_2.11-2.4.0.tgz
# 复制到 /usr/local 目录
mv kafka_2.11-2.4.0 /usr/local/kafka_2.11-2.4.0
配置
cd /usr/local/kafka_2.11-2.4.0/config
vi server.properties# 增加如下配置,ip为kafka所在服务器的地址(内网ip)
listeners=PLAINTEXT://182.43.11.48:9092
# 增加如下配置,可选,ip为kafka所在服务器的地址(供外部访问的ip)
advertised.listeners=PLAINTEXT://182.43.11.48:9092
# 增加如下配置,zookeeper所在服务器的地址
zookeeper.connect=182.43.11.48:2181# 保存
:wq
启动
# 进入安装目录
cd /usr/local/kafka_2.11-2.4.0
# 启动
nohup bin/kafka-server-start.sh config/server.properties &
# kafka占用端口9092,查看监听情况
netstat -tunlp | egrep 9092# 开放9092端口
firewall-cmd --add-port=9092/tcp --permanent
firewall-cmd --reload# 停止
bin/kafka-server-stop.sh config/server.properties

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

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

相关文章

OpenGL —— 2.7、绘制多个自旋转的贴图正方体(附源码,glfw+glad)

源码效果 C源码 纹理图片 需下载stb_image.h这个解码图片的库,该库只有一个头文件。 具体代码: vertexShader.glsl #version 330 corelayout(location 0) in vec3 aPos; layout(location 1) in vec2 aUV;out vec2 outUV;uniform mat4 _modelMatrix; …

微信小程序进阶——Flex弹性布局轮播图会议OA项目(首页)

目录 一、Flex弹性布局 1.1 什么是Flex弹性布局 1.1.1 详解 1.1.2 图解 1.1.3 代码演示效果 1.2 Flex弹性布局的核心概念 1.3 Flex 弹性布局的常见属性 1.4 Flex弹性布局部分属性详解 1.4.1 flex-direction属性 1.4.2 flex-wrap属性 1.4.3 flex-flow属性 1.4.4 ju…

DFS(分布式文件系统)与 DFSR(分布式文件系统复制)的区别

DFS(分布式文件系统)和 DFSR(分布式文件系统复制)是两种不同的技术,尽管它们在名称上有一些相似之处,但它们的用途和功能有所不同。 DFS(分布式文件系统) DFS 是一种用于创建和管理…

Win10系统开机启动文件夹在哪里找?

Win10系统开机启动文件夹在哪里找?Win10系统开机启动文件夹是一个非常重要的目录,它决定了电脑在开机的时候,会有哪些应用程序是自动启动。但是,很多新手用户不知道Win10电脑内开机启动文件夹的具体位置,下面小编介绍开…

eNSP笔记②

动态路由 RIP [适用于小型网络] 静态路由是加上非直连的网段,动态路由是加上直连的网段 动态路由就是要宣告它要去的网段,在图中可以看到,一台路由需要宣告两个网段,路由A分别宣告10.0.0.0与192.168.1.0,路由B宣告10.…

ArcGIS在VUE框架中的构建思想

项目快要上线了,出乎意料的有些空闲时间。想着就把其他公司开发的一期代码里面,把关于地图方面的代码给优化一下。试运行的时候,客户说控制台有很多飘红的报错,他们很在意,虽然很不情愿,但能改的就给改了吧…

JSX的本质

一、本质 React.createElement即h函数,返回vnode第一个参数,可能是组件,也可能是html tag组件名,首字母必须大写(React规定) 二、babel试一试 (babel集成了jsx的编译环境) // JSX…

Java:SpringBoot实现JDK动态代理和CGLIB动态代理

目录 1. JDK 动态代理2. CGLIB 动态代理总结参考文章 需要代理的对象 // 接口 public interface PayService {void pay(); }// 实现 public class AliPayService implements PayService {Overridepublic void pay() {System.out.println("AliPayService");} }1. JDK…

【反射】Constructor类

Constructor类中包含了构造方法定义的详细信息,可以使用Constructor类中提供的方法来获取构造方法的信息,下面我们先获取Constructor对象,再介绍如何使用Constructor类中的newInstance方法创建对象。 一、准备工作 在src/test/java目录的cn…

自定义反序列化类将LocalDate时间格式转为 LocalDateTime

从前端接收数据反序列化成类,如果时间格式不一致可能会反序列化失败 public class StorageDTO implements Serializable {private static final long serialVersionUID 1L;......//实体类中格式为JsonFormat(pattern "yyyy-MM-dd")JsonDeserialize(using CustomL…

matlab奇技淫巧——绘制三维地图

在数据处理工作中,常常会用到地图的绘制,最常用的自然是绘制平面的区域/全球地图,通过 worldmap(world) % 创建世界地图坐标区域 load coastlines % 导入海岸线数据 plotm(coastlat,coastlon)即可绘制,效果…

Vue常见的指令及使用方法

在 Vue 中&#xff0c;指令是一种特殊的属性&#xff0c;用于在 HTML 元素上绑定数据和实现交互。Vue 提供了多个常见的指令&#xff0c;让我们来逐一介绍并给出使用示例。 v-bind v-bind 指令用于绑定数据到 HTML 元素的属性&#xff0c;可以动态地更新元素的属性值。 <im…

Talk | UCSD博士生刘明华:在开放的世界中理解和生成3D物体

本期为TechBeat人工智能社区第539期线上Talk。 北京时间10月19日&#xff08;周四&#xff09;20:00&#xff0c;加州大学圣地亚哥分校博士生—刘明华的Talk已准时在TechBeat人工智能社区开播&#xff01; 他与大家分享的主题是: “在开放的世界中理解和生成3D物体”&#xff0…

用护眼灯到底好不好?好用热门的护眼台灯推荐

现在市面上做护眼灯的品牌非常多&#xff0c;有的是脚踏实地&#xff0c;真正做保护消费者眼睛的产品&#xff0c;有的则是夸大宣传&#xff0c;以次充好来收割很多不明真相的群众。其实护眼灯的防蓝光是做不到完全无蓝光的&#xff0c;那些宣传完全无蓝光的商家&#xff0c;完…

会议剪影 | 思腾合力携AI服务器亮相PRCV 2023,并作主题演讲

第六届中国模式识别与计算机视觉大会&#xff08;PRCV 2023&#xff09;于2023年10月13日至15日在厦门国际会议中心酒店举办。本届会议主题为“相约鹭岛&#xff0c;启智未来”。 会议旨在汇聚国内国外模式识别和计算机视觉理论与应用研究的广大科研工作者及工业界同行&#xf…

2023年中国工业气体行业研究报告

第一章 行业概况 1.1 定义 工业气体行业是一个不可或缺的产业领域&#xff0c;它为多种行业提供关键的产品和服务。工业气体&#xff0c;包括氧气、氮气、氩气、二氧化碳、氦气、氢气及特种气体等&#xff0c;是现代工业生产和科学研究的基础。这些气体在不同的领域具有广泛的…

mysql体系结构及引擎

目录 一、mysql体系结构 二、存储引擎简介 2.1查看当前数据库支持的存储引擎 三、存储引擎的特点 3.1innodb 3.2myisam 3.3memory 四、存储引擎的选择 一、mysql体系结构 连接层 最上层是一些客户端和连接服务&#xff0c;主要完成一些类似于连接处理&#xff0c;授权认…

C- 使用原子变量实现自旋锁

自旋锁 自旋锁&#xff08;Spinlock&#xff09;是一种常用于多线程编程中的低开销锁&#xff0c;其特点是当线程尝试获取锁而锁已被其他线程占用时&#xff0c;该线程会处于一个持续的忙等待&#xff08;busy-wait&#xff09;状态&#xff0c;直到它可以获取到锁为止。这种方…

哈夫曼树的建立(C++,最优树)

介绍&#xff1a; 哈夫曼树&#xff08;Huffman Tree&#xff09;是一种用于数据压缩的树形数据结构。它是由刚特哈夫曼于1952年发明的。 哈夫曼树的特点是&#xff1a;对于一个长度为n的字符集&#xff0c;它可以将每个字符在树上表示为一个唯一的二进制编码。在哈夫曼树中&am…

NSSCTF做题(10)

叫10好听一点&#xff0c;就是补9的 第7页的内容 [SWPUCTF 2022 新生赛]ez_sql get传参说是不安全&#xff0c;那就只能用post了 有回显了&#xff0c;两个假的flag 发现万能密码 1 or 11#变成了 11# 11# 1 11#1# 11# 11# 发现or和空格都无了&#xff0c;union也过滤 …