温馨提示×

如何在debian配kafka主题

小樊
39
2026-09-16 01:08:40
栏目: 智能运维

在 Debian 上“配置 Kafka 主题”通常分三步:安装 Kafka(或连接已有 Kafka)→ 启动服务 → 用命令行创建/修改主题。下面给你一套最常用、可直接照做的流程。


一、环境准备(Debian)

1. 安装 Java(Kafka 依赖)

sudo apt update
sudo apt install -y default-jdk
java -version

2. 下载 Kafka

以 Kafka 3.6 为例(可换版本):

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

二、启动 Kafka(单机版)

1. 启动 Zookeeper(老版本需要)

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

2. 启动 Kafka

新开一个终端:

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

✅ Kafka 3.x 也支持 KRaft 模式(无 Zookeeper),但新手建议先用 Zookeeper。


三、创建 Kafka 主题(重点)

1. 创建主题

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

说明:

  • --partitions 3:3 个分区
  • --replication-factor 1:单节点只能为 1

2. 查看主题

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

3. 修改主题(如增加分区)

bin/kafka-topics.sh \
  --alter \
  --topic test-topic \
  --partitions 5 \
  --bootstrap-server localhost:9092

⚠️ Kafka 不能减少分区,也不能直接改副本数(需用 reassignment)


四、测试主题(可选)

生产者

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

消费者

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

五、常见配置文件位置

文件 作用
config/server.properties Kafka 主配置
config/zookeeper.properties Zookeeper 配置
log.dirs 消息存储目录

六、如果你只是“连已有 Kafka”

只需:

bin/kafka-topics.sh \
  --create \
  --topic my-topic \
  --bootstrap-server kafka-host:9092

不用安装 Kafka Server,只保留 kafka_2.13-*.tgz 的 bin 工具即可。


如果你愿意,可以告诉我:

  • 单机 / 集群
  • Zookeeper 还是 KRaft
  • 是否需要 systemd 自启

我可以直接给你一份 Debian 专用配置方案

0