首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >CentOS7 安装Kafka-单机

CentOS7 安装Kafka-单机

原创
作者头像
郑郑SunUp
修改2025-01-06 13:33:19
修改2025-01-06 13:33:19
7230
举报
文章被收录于专栏:LinuxLinux

安装CentOS7

安装CentOS7

安装JDK11,配置JAVA_HOME (CentOS 7 64bit)

安装jdk11

配置主机名和IP映射

1.概述

配置主机名与IP地址映射后,访问服务器上部署的服务就不用在记住IP地址,只需要输入服务器名称即可访问服务,相比记住IP地址访问应用要方便。

2.配置主机名

2.1.查看主机名
代码语言:txt
复制
uname -n
2.2.修改主机名
代码语言:txt
复制
vim /etc/hostname

删除默认的名称,直接写主机名即可。

3.配置主机名映射IP地址

3.1. 主机名映射IP地址
代码语言:txt
复制
vim /etc/hosts

将主机IP地址和主机名添加到最下面

3.2.测试主机名映射IP地址
  • 重启系统
  • ping 主机名

关闭防火墙&防火墙开机自启动

Linux安装CentOS后常见问题--防火墙

安装&启动Zookeeper

1. 环境准备

在安装 Zookeeper 之前,需要确保已经安装了 Java 环境。Zookeeper 依赖于 Java 运行环境(JRE),因此需要提前安装好 JDK 并配置好环境变量。

2. 安装 Zookeeper

下载 Zookeeper 安装包:

代码语言:txt
复制
cd /usr/local/
代码语言:txt
复制
wget https://dlcdn.apache.org/zookeeper/zookeeper-3.8.4/apache-zookeeper-3.8.4-bin.tar.gz

解压安装包:

代码语言:txt
复制
tar -zxvf apache-zookeeper-3.8.4-bin.tar.gz

将解压后的目录修改文件名(可不修改)

代码语言:txt
复制
mv apache-zookeeper-3.8.4-bin zookeeper

3. 配置 Zookeeper

配置zoo.cfg

进入到conf目录拷贝一个zoo_sample.cfg并完成配置

创建数据存储目录

代码语言:txt
复制
cd /usr/local/zookeeper/
代码语言:txt
复制
mkdir zkDataDir

修改zoo.cfg

代码语言:txt
复制
cd conf/
代码语言:txt
复制
cp  zoo_sample.cfg  zoo.cfg
代码语言:txt
复制
vim zoo.cfg 

修改存储目录:dataDir=/usr/local/zookeeper/zkDataDir

4. 启动 Zookeeper

执行以下命令启动 Zookeeper:

代码语言:txt
复制
cd /usr/local/zookeeper/bin
代码语言:txt
复制
zkServer.sh start ../conf/zoo.cfg

启动成功后,可以通过以下命令查看 Zookeeper 的状态:

代码语言:txt
复制
zkServer.sh status

关闭 Zookeeper:

代码语言:txt
复制
zkServer.sh stop

5.配置快捷启动

代码语言:txt
复制
vim ~/.bash_profile
代码语言:txt
复制
# .bash_profile

# Get the aliases and functions
if [ -f ~/.bashrc ]; then
        . ~/.bashrc
fi

# User specific environment and startup programs

PATH=$PATH:$HOME/bin

export PATH

#添加这3行
alias zkstart="sh /usr/local/zookeeper/bin/zkServer.sh start /usr/local/zookeeper/conf/zoo.cfg"
alias zkstatus="sh /usr/local/zookeeper/bin/zkServer.sh status"
alias zkstop="sh /usr/local/zookeeper/bin/zkServer.sh stop"
代码语言:txt
复制
source ~/.bash_profile
代码语言:txt
复制
zkstart
zkstatus
zkstop

安装&启动|关闭Kafka

新版本的kafka自带有zookeeper,其实自带的zookeeper完全够用。

我也是安装到后边才发现的哈哈哈!!!

1、下载kafak包并解压

代码语言:txt
复制
cd /usr/local
代码语言:txt
复制
wget https://dlcdn.apache.org/kafka/3.9.0/kafka_2.12-3.9.0.tgz
代码语言:txt
复制
tar -xzf kafka_2.12-3.9.0.tgz
代码语言:txt
复制
mv kafka_2.12-3.9.0 kafka

2、修改zookeeper配置文件

代码语言:txt
复制
cd kafka/config/

vim zookeeper.properties

把 dataDir修改为以下
dataDir=/usr/local/kafka/zookeeperDataDir

添加以下:
tickTime=2000
initLimit=10
syncLimit=5

3、修改kafak配置文件

代码语言:txt
复制
vim server.properties

把 log.dirs 修改为以下
log.dirs=/usr/local/kafka/kafkaLogDirs

把 listeners 修改为以下(CentOS7_Master_Kafka_001为主机名称)
listeners=PLAINTEXT://CentOS7_Master_Kafka_001:9092

把 zookeeper.connect 修改为以下(192.168.42.133为ip地址)
zookeeper.connect=192.168.42.133:2181

4、启动

先启动zookeeper

代码语言:txt
复制
cd /usr/local/kafka/bin
sh zookeeper-server-start.sh  ../config/zookeeper.properties &

后台 ps -ef 确认zookeeper进程是否存在

再启动kafka

代码语言:txt
复制
/usr/local/kafka/bin
sh kafka-server-start.sh ../config/server.properties &
两种方式都行
sh kafka-server-start.sh -daemon ../config/server.properties 

后台 ps -ef 确认kafka进程是否存在

配置快捷启动-个人习惯:

代码语言:txt
复制
vim ~/.bash_profile

最下面添加

代码语言:txt
复制
alias kafkazkstart="sh /usr/local/kafka/bin/zookeeper-server-start.sh  /usr/local/kafka/config/zookeeper.properties > /usr/local/kafka/bin/zk.log &"
alias kafkazkstop="sh /usr/local/kafka/bin/zookeeper-server-stop.sh"
alias kafkastart="sh /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties > /usr/local/kafka/bin/kf.log &"
alias kafkastop="sh /usr/local/kafka/bin/kafka-server-stop.sh"
代码语言:txt
复制
source ~/.bash_profile

再次启停zookeeper和kafka:

代码语言:txt
复制
kafkazkstart
kafkazkstop

kafkastart
kafkastop

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 安装CentOS7
  • 安装JDK11,配置JAVA_HOME (CentOS 7 64bit)
  • 配置主机名和IP映射
    • 1.概述
    • 2.配置主机名
    • 3.配置主机名映射IP地址
  • 关闭防火墙&防火墙开机自启动
  • 安装&启动Zookeeper
    • 1. 环境准备
    • 2. 安装 Zookeeper
    • 3. 配置 Zookeeper
    • 4. 启动 Zookeeper
    • 5.配置快捷启动
  • 安装&启动|关闭Kafka
    • 1、下载kafak包并解压
    • 2、修改zookeeper配置文件
    • 3、修改kafak配置文件
    • 4、启动
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档