温馨提示×

ubuntu kafka配置咋设置

小樊
45
2026-09-08 14:12:30
栏目: 智能运维

下面给你一份 Ubuntu 上 Kafka 基础配置与启动 的实用说明(以 Kafka 3.x + Kafka 自带 Zookeeper 为例,最常见、适合入门和测试)。


一、环境准备

1. 安装 Java

Kafka 需要 JDK 8 或以上:

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

二、下载并安装 Kafka

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

三、基础配置(重点)

1. Zookeeper 配置(测试环境可默认)

/opt/kafka/config/zookeeper.properties

常用参数:

dataDir=/tmp/zookeeper
clientPort=2181

2. Kafka 核心配置

/opt/kafka/config/server.properties

最常用修改项:

# broker 唯一 ID
broker.id=0

# 监听地址(本机)
listeners=PLAINTEXT://:9092

# 对外暴露地址(很重要,否则远程连不上)
advertised.listeners=PLAINTEXT://你的IP:9092

# 日志存储目录
log.dirs=/tmp/kafka-logs

# Zookeeper 地址
zookeeper.connect=localhost:2181

远程访问必须配置 advertised.listeners


四、启动 Kafka

1. 启动 Zookeeper

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

2. 启动 Kafka

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

查看进程:

jps

五、基本测试

1. 创建 Topic

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

2. 生产消息

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

3. 消费消息

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

六、开机自启(systemd 示例)

Kafka service

sudo vim /etc/systemd/system/kafka.service
[Unit]
Requires=zookeeper.service
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=on-abnormal

[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable kafka

七、常见问题

  • 连不上 Kafka → 检查 advertised.listeners
  • 端口被占用 → 修改 9092
  • 生产环境 → 建议 Kafka 3.3+ 使用 KRaft(无 Zookeeper)

如果你是用 Docker / KRaft / 集群 / 云服务器,告诉我场景,我可以给你对应配置。

0