Kafka 安装教程 ( Liunx 平台 )

安装 Kafka  （ 单机模式 ）以 linux 系统为例 :

关闭防火墙

systemctl stop firewalld
systemctl disable firewalld

1. 安装 java 依赖环境

1.1 下载 jdk

官网 https://www.oracle.com/java/technologies/downloads/

命令

cd /
wget https://download.oracle.com/java/19/latest/jdk-19_linux-x64_bin.tar.gz
tar -zxvf jdk-19_linux-x64_bin.tar.gz #解压 
mv jdk-19.0.1/ jdk #重命名

配置环境变量

vi /etc/profile
添加
export JAVA_HOME=/jdk #jdk安装目录 
export JRE_HOME=${JAVA_HOME}/jre #jre安装目录
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=$PATH:${JAVA_HOME}/bin:${JRE_HOME}/bin

保存后刷新环境变量

source /etc/profile

检查java 环境

java -version

mac 配置 JAVA_HOME

export JAVA_HOME="/Library/Java/JavaVirtualMachines/jdk***.jdk/Contents/Home"
export PATH="$PATH:$JAVA_HOME/bin"

2. 安装 kafka

1. 下载 Kafka

官网 :  https://kafka.apache.org/downloads

linux 下载命令

cd /
wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz

2. 解压

tar -zxvf kafka_2.13-3.3.1.tgz # 解压
mv kafka_2.13-3.3.1 kafka # 重命名

3. 基于 kraft 运行

3.1 修改配置 server.properties

基于 kafka 可以无需安装 zookeeper，kafka  配置位置 : /kafka/config/kraft 。

# 配置文件 server.properties
# 单机运行仅需修改 
log.dirs=/tmp/kraft-combined-logs 
->
log.dirs=/kraft-datas

3.2 格式化本地存储

# 生成一个 uuid
/kafka/bin/kafka-storage.sh random-uuid
# 请记录保存生成的uuid 集群时需要使用
# 格式化命令
/kafka/bin/kafka-storage.sh format -t ctkx9RYUS1ixC16N444e8g -c /kafka/config/kraft/server.properties

3.3 启动

 /kafka/bin/kafka-server-start.sh /kafka/config/kraft/server.properties
 # 后台运行
 /kafka/bin/kafka-server-start.sh -daemon /kafka/config/kraft/server.properties

3.4 添加话题

/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic first

3.5 创建消费者监听

/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first

3.6 生产者发布消息

/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic first

此时建议您打开3个命令窗口分别用于启动kafka、生产者、消费者。

在上面的窗口中生产者发送消息、消费者接收到消息，证明 kafka 单机环境部署完毕。

3.7 查看话题

/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --list