kafka主题debian如何建

在 Debian 系统上创建 Kafka 主题（topic），一般步骤如下（假设你已经安装并启动了 Kafka）。

一、前提条件

确保以下服务已启动：

• Zookeeper（老版本 Kafka 需要）
• Kafka Broker

启动示例（以官方二进制包为例）：

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

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

二、创建 Kafka 主题

1️⃣ 使用 kafka-topics.sh（最常用）

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

参数说明：

• --topic：主题名称
• --partitions：分区数
• --replication-factor：副本数（不能超过 broker 数量）
• --bootstrap-server：Kafka 地址（推荐，老版本用 --zookeeper）

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

2️⃣ 老版本（连接 Zookeeper）

bin/kafka-topics.sh \
  --create \
  --zookeeper localhost:2181 \
  --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

四、Debian 上使用 apt 安装 Kafka（可选）

Debian 官方源通常 没有 Kafka，一般方式是：

# 下载 Kafka
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1

五、常见问题

❌ replication-factor 大于 broker 数

报错：

InvalidReplicationFactorException

✅ 改为 --replication-factor 1

❌ 连接失败

检查：

netstat -tunlp | grep 9092

或

telnet localhost 9092

如果你是在 Docker / Kubernetes / Debian 系统服务方式运行 Kafka，可以告诉我，我可以给你对应的建主题方式。