centos Kafka主题怎么建

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

一、前提条件

1. Zookeeper 已启动（老版本 Kafka）
2. Kafka 已启动

启动 Kafka（示例）

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

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

Kafka 2.8+ 可使用 KRaft 模式，不依赖 Zookeeper

二、创建 Kafka 主题

1️⃣ 进入 Kafka 安装目录

cd /opt/kafka   # 根据你的安装路径

2️⃣ 使用 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 地址

3️⃣ 老版本（使用 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

四、删除主题（可选）

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

需要在 server.properties 中开启：

delete.topic.enable=true

五、测试主题（生产 / 消费）

生产消息

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

六、常见问题

❌ replication factor: 1 larger than available brokers: 0
→ Kafka 没启动或 broker 数量不足

❌ 主题创建成功但消费不到
→ 检查 --from-beginning 或 group id

如果你用的是：

• Docker Kafka
• KRaft 模式
• 集群环境

可以告诉我，我可以给你对应命令。