kafka在ubuntu如何设置

下面以 Ubuntu（20.04 / 22.04 为例） 说明 Kafka 的安装与基本配置，假设你已经安装了 Java（JDK 8 或以上）。

一、前置条件：安装 Java

Kafka 依赖 Java 运行环境。

sudo apt update
sudo apt install openjdk-11-jdk -y

验证：

java -version

二、下载并安装 Kafka（官方二进制包）

1. 下载 Kafka

cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz

版本号可到官网查看最新：https://kafka.apache.org/downloads

2. 解压

sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka

三、启动 Kafka（依赖 Zookeeper）

1. 启动 Zookeeper

cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

默认端口：2181

2. 启动 Kafka

新开一个终端：

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

默认端口：9092

四、基本配置修改（常见）

1. 修改 Kafka 监听地址

编辑：

nano config/server.properties

常见修改：

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://你的服务器IP:9092

如果是本地测试：

listeners=PLAINTEXT://localhost:9092

2. 修改日志存储目录

log.dirs=/opt/kafka/kafka-logs

五、测试 Kafka 是否可用

1. 创建 Topic

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

2. 查看 Topic

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

3. 发送消息（生产者）

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

4. 消费消息（消费者）

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

六、设置 Kafka 为系统服务（可选）

1. 创建 systemd 服务（示例）

Zookeeper

sudo nano /etc/systemd/system/zookeeper.service

[Unit]
Description=Zookeeper Service
After=network.target

[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=always

[Install]
WantedBy=multi-user.target

Kafka

sudo nano /etc/systemd/system/kafka.service

[Unit]
Description=Apache Kafka
After=zookeeper.service

[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=always

[Install]
WantedBy=multi-user.target

2. 启动服务

sudo systemctl daemon-reload
sudo systemctl start zookeeper
sudo systemctl start kafka

开机自启：

sudo systemctl enable zookeeper
sudo systemctl enable kafka

七、常见问题

1. Kafka 启动失败

检查 Java 是否安装
检查端口是否被占用

netstat -tunlp | grep 9092

2. 本地可以连，远程连不上

检查 advertised.listeners
检查防火墙

sudo ufw allow 9092

八、Kafka 3.x 新特性（重要）

Kafka 3.x 可以不依赖 Zookeeper（KRaft 模式），如果你需要，我可以单独给你 KRaft 模式配置方案。

如果你告诉我：

✅ Ubuntu 版本
✅ 单机 / 集群
✅ 是否生产环境
✅ 是否使用 KRaft

我可以给你 更精确的配置方案。