kafka主题在debian怎建

在 Debian 上创建 Kafka 主题，前提是你已经安装并启动了 Kafka（以及 Zookeeper，或使用了 KRaft 模式）。下面分步骤说明。

一、前置条件

1. 已安装 Kafka

假设 Kafka 安装在：

/opt/kafka

2. 已启动服务

如果是 Zookeeper 模式

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

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

如果是 KRaft 模式（新版本 Kafka）

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

二、创建 Kafka 主题

方式一：使用 Zookeeper（老版本常见）

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

方式二：使用 Bootstrap Server（推荐 ✅）

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

参数说明：

• --topic：主题名
• --partitions：分区数
• --replication-factor：副本数（不能大于 broker 数量）

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

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

查看主题详情：

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

四、测试主题（可选）

发送消息

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

消费消息

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

五、常见问题

1. 提示 missing required argument

通常是 Kafka 版本问题：

• 新版本：用 --bootstrap-server
• 老版本：用 --zookeeper

2. 副本数大于 broker 数

报错：

replication factor: 3 larger than available brokers: 1

解决：改成 --replication-factor 1

如果你愿意，可以告诉我：

• Kafka 版本
• 是否用 Docker
• 单节点还是集群

我可以给你更精确的命令。