Kafka安装教程及相关注意事项

Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。下文将详细介绍Kafka安装及配置注意事项。

一、Kafka下载

1、访问kafka官网根据实际情况下载对应的版本

2、JDK的版本最好是17+

二、Kafka安装

前置条件：

安装 Java（至少 Java 8）

java -version # 检查是否已安装成功

1、Kafka Linux/macOS 安装指南

步骤 1：下载 Kafka

wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1

步骤 2：启动服务

1.启动 ZooKeeper（Kafka 的依赖服务）：

bin/zookeeper-server-start.sh config/zookeeper.properties

2.启动 Kafka 服务（新终端窗口）：

bin/kafka-server-start.sh config/server.properties

2、Kafka Windows安装指南

步骤 1：下载并解压

下载并解压到目录（如 C:\kafka）

步骤 2：启动服务

1、启动 ZooKeeper（管理员运行 CMD）：

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

2、启动 Kafka 服务（新 CMD 窗口）：

.\bin\windows\kafka-server-start.bat .\config\server.properties

三、验证Kafka安装（所有系统通用）

1、创建测试主题

bin/kafka-topics.sh –create –topic test-topic –bootstrap-server localhost:9092 –partitions 1 –replication-factor 1

Windows 替换为 .\bin\windows\kafka-topics.bat

2、生产消息

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

输入任意消息（如 Hello Kafka!）后按 Ctrl+C 退出

3、消费消息

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

若看到发送的消息，说明安装成功！

四、Kafka常用命令

功能	命令
查看主题列表	bin/kafka-topics.sh –list –bootstrap-server localhost:9092
删除主题	bin/kafka-topics.sh –delete –topic test-topic –bootstrap-server localhost:9092
查看消费者组	bin/kafka-consumer-groups.sh –list –bootstrap-server localhost:9092

五、Kafka注意事项

1、端口冲突：

oZooKeeper 默认端口：2181

oKafka 默认端口：9092

o若占用，修改 config/server.properties 中的 port 和 zookeeper.connect

2、生产环境配置

o修改 config/server.properties：

listeners=PLAINTEXT://your-server-ip:9092
log.dirs=/path/to/kafka-logs

3、守护进程启动（Linux/macOS）：

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log &nohup bin/kafka-server-start.sh config/server.properties > kafka.log &