CentOS7 安装Kafka

CentOS7 安装Kafka

安装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

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

.配置主机名映射IP地址

.1. 主机名映射IP地址

代码语言：txt复制

vim /etc/hosts

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

.2.测试主机名映射IP地址

• 重启系统
• ping 主机名

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

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

安装&启动Zookeeper

1. 环境准备

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

2. 安装 Zookeeper

下载 Zookeeper 安装包：

代码语言：txt复制

cd /usr/local/

代码语言：txt复制

wget .8.4/apache-zookeeper-.8.gz

解压安装包：

代码语言：txt复制

tar -zxvf apache-zookeeper-.8.gz

将解压后的目录修改文件名（可不修改）

代码语言：txt复制

mv apache-zookeeper-.8.4-bin zookeeper

. 配置 Zookeeper

配置

进入到conf目录拷贝一个zoo_并完成配置

创建数据存储目录

代码语言：txt复制

cd /usr/local/zookeeper/

代码语言：txt复制

mkdir zkDataDir

修改

代码语言：txt复制

cd conf/

代码语言：txt复制

cp  zoo_  

代码语言：txt复制

vim  

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

4. 启动 Zookeeper

执行以下命令启动 Zookeeper：

代码语言：txt复制

cd /usr/local/zookeeper/bin

代码语言：txt复制

zkServer.sh start ../conf/

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

代码语言：txt复制

zkServer.sh status

关闭 Zookeeper：

代码语言：txt复制

zkServer.sh stop

5.配置快捷启动代码语言：txt复制

vim ~/.bash_profile

代码语言：txt复制

# .bash_profile

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

# User specific environment and startup programs

PATH=$PATH:$HOME/bin

export PATH

#添加这行
alias zkstart="sh /usr/local/zookeeper/bin/zkServer.sh start /usr/local/zookeeper/conf/"
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 .9.0/kafka_2.12-.9.

代码语言：txt复制

tar -xzf kafka_2.12-.9.

代码语言：txt复制

mv kafka_2.12-.9.0 kafka

2、修改zookeeper配置文件代码语言：txt复制

cd kafka/config/

vim zookeeper.properties

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

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

、修改kafak配置文件代码语言：txt复制

vim server.properties

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

把 listeners 修改为以下（CentOS7_Master_Kafka_001为主机名称）
listeners=PLAITEXT://CentOS7_Master_Kafka_001:9092

把  修改为以下（192.168.42.1为ip地址）
=192.168.42.1: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