温馨提示×

kafka主题debian怎么建

小樊
45
2026-09-22 02:15:15
栏目: 智能运维

在 Debian 系统上创建 Kafka 主题,通常有两种方式:命令行方式(最常用) 和 通过 Kafka 管理工具/代码。下面重点讲 命令行方式,这也是在 Debian 服务器上最常见的做法。


一、前提条件(Debian 上)

  1. 已安装并启动:
    • ZooKeeper(老版本 Kafka)
    • Kafka Broker
  2. Kafka 安装目录存在(例如 /opt/kafka 或 /usr/local/kafka)

二、使用 Kafka 命令行创建主题(推荐)

1️⃣ 进入 Kafka 目录

cd /opt/kafka

(具体路径以你的安装位置为准)


2️⃣ 创建主题(Kafka 2.x 及以后,推荐方式)

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

参数说明:

  • --topic:主题名
  • --bootstrap-server:Kafka 地址(新版本推荐)
  • --partitions:分区数
  • --replication-factor:副本数(不能大于 broker 数量)

✅ Kafka 2.2+ 推荐使用 --bootstrap-server


3️⃣ 老版本(依赖 ZooKeeper)

bin/kafka-topics.sh \
  --create \
  --topic test-topic \
  --zookeeper localhost:2181 \
  --partitions 3 \
  --replication-factor 1

三、查看主题是否创建成功

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

查看主题详情:

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

四、常见问题(Debian 环境)

❌ 报错:broker 不可用

  • 确认 Kafka 已启动:
jps

应看到 Kafka

启动 Kafka:

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

❌ replication-factor 大于 broker 数量

例如只有 1 个 broker,却设置:

--replication-factor 2

会报错


五、Debian 系统服务方式(可选)

如果你是用 apt 安装的 Kafka(较少见),可能命令在:

/usr/share/kafka/bin/kafka-topics.sh

六、示例:完整流程

# 启动 Kafka
bin/kafka-server-start.sh -daemon config/server.properties

# 创建主题
bin/kafka-topics.sh --create \
  --topic my-topic \
  --bootstrap-server localhost:9092 \
  --partitions 1 \
  --replication-factor 1

如果你愿意,我可以:

  • 帮你写 systemd 服务
  • 讲 Kafka 在 Debian 上怎么安装
  • 或给你 Python / Java 创建主题示例

你现在 Kafka 是已经装好了,还是刚开始装?

0 踩