2-jdk8环境下安装Kafka

2-jdk8环境下安装Kafka

本文介绍的是 Linux 系统下 Kafka 安装方式，kafka 依赖于 Zookeeper，Zookeeper安装方式请看：
https://blog.csdn.net/sql2008help/article/details/130669778?spm=1011.2415.3001.5331

① 下载

进入官网 https://kafka.apache.org/downloads 点击下载按钮

②上传压缩包并解压

1）新建 kafka 目录，此处文件夹为 /usr/local

mkdir kafka

2）将压缩包上传到 /usr/local/kafka目录下

3）解压

tar -zxvf kafka_2.13-3.7.0.tgz

③配置kafka

1）配置环境变量

vi /etc/profile

在末尾追加

export KAFKA_HOME=/usr/local/kafka/kafka_2.13-3.7.0
export PATH=$PATH:$KAFKA_HOME/bin

执行如下命令使配置生效

source /etc/profile

2）修改配置文件，配置server.properties
第一步，进入目录 /usr/local/kafka/kafka_2.13-3.7.0/config

备份 server.properties 文件

cp server.properties server_bak.properties

第二步，修改 server.properties 文件

vi server.properties

修改如下两处配置：

advertised.listeners=PLAINTEXT://192.168.174.128:9092
# 配置kafka连接的zookeeper地址以及路径，也可以保持默认，默认配置是 localhost:2181
zookeeper.connect=localhost:2181/kafkaTest
log.dirs=/usr/local/kafka/kafka_2.13-3.7.0/logs

以上日志目录没有需要手动创建

④ 启动kafka

cd /usr/local/kafka/kafka_2.13-3.7.0/bin
kafka-server-start.sh ../config/server.properties
#后台启动，使用命令
kafka-server-start.sh -daemon ../config/server.properties

出现如下日志，说明启动成功

登录Zookeeper客户端进行验证，

zkCli.sh
ls /
ls /kafkaTest

⑤ 停止kafka

kafka-server-stop.sh

⑥ 创建主题（Topic）和测试Kafka

进入 kafka bin 目录

# 创建一个名为"test"的主题，分区数为1，副本因子为1
$KAFKA_HOME/bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
 
# 发送一些消息到"test"主题
$KAFKA_HOME/bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

使用消费者来查看这些消息

$KAFKA_HOME/bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092