温馨提示×

kafka主题怎样建debian

小樊
34
2026-10-12 16:56:31
栏目: 智能运维

在 Debian 系统上创建 Kafka 主题(topic),前提是你已经安装并启动了 Kafka(以及 ZooKeeper 或 KRaft)。下面按常见场景给你说明。


一、前提条件(Debian 上)

确保以下服务已启动:

1. 使用 ZooKeeper 模式(传统)

# 启动 ZooKeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

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

2. 使用 KRaft 模式(Kafka 3.x+,新方式)

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

二、创建 Kafka 主题(最常用方式)

1️⃣ 进入 Kafka 安装目录

cd /opt/kafka   # 或你的安装路径

2️⃣ 创建主题(ZooKeeper 模式)

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

说明:

  • test-topic:主题名
  • partitions 3:分区数
  • replication-factor 1:副本数(单机只能为 1)

3️⃣ 创建主题(KRaft / Bootstrap 模式,推荐)

bin/kafka-topics.sh \
  --create \
  --bootstrap-server localhost:9092 \
  --topic test-topic \
  --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

删除主题

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

四、Debian 上常见问题

❌ 报错:replication factor larger than available brokers

原因:副本数 > 当前 broker 数量
解决:

--replication-factor 1

❌ 报错:找不到 JAVA

解决:

sudo apt install default-jdk
java -version

五、用 systemd 管理(Debian 推荐)

如果你是用 apt 或手动安装,可以告诉我,我可以帮你写:

  • kafka.service
  • zookeeper.service

如果你是指:

  • ✅ Debian 上怎么安装 Kafka
  • ✅ Docker 里建 Kafka 主题
  • ✅ 用 Python/Java 建主题

可以告诉我,我给你对应示例。

0 踩