Kafka主题的创建与删除通过kafka-topics.sh实现：创建需指定--bootstrap-server、--topic、--partitions和--replication-factor；删除前须确保delete.topic.enable=true，否则仅标记删除。

创建和删除 Kafka 主题主要靠 kafka-topics.sh 这个命令行工具，核心是通过 --bootstrap-server 指定集群地址，再配合 --create 或 --delete 动作完成操作。注意删除前必须确认配置已启用，否则只是标记删除。

创建主题：指定分区、副本和名称

使用 --create 参数，必须提供主题名、分区数和副本因子。Kafka 会自动分配副本到可用 broker 上（除非手动指定）。

• --bootstrap-server：必填，格式为 host:port，可写多个用逗号分隔（如 broker1:9092,broker2:9092）
• --topic：主题名称，不能含点号（.）、下划线（_）混用，建议全小写字母加短横线
• --partitions：分区数量，影响并行消费能力和数据分布，后续只能增加不能减少
• --replication-factor：副本数，必须 ≤ 当前可用 broker 数量，否则创建失败

示例命令：

bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic user-events --partitions 6 --replication-factor 3

删除主题：需提前开启删除开关

Kafka 默认不真正删除主题数据，只打上删除标记。要立即生效，必须确保 broker 配置中 delete.topic.enable=true（该参数在较新版本中默认为 true，但生产环境仍建议显式检查）。

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

• 执行删除命令后，Kafka 会在后台异步清理数据，通常几秒内完成
• 如果配置未开启，命令会提示 “Topic deletion is disabled”
• 删除不可逆，主题下所有消息、偏移量、配置全部清除

示例命令：

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

验证操作是否成功

创建后或删除后，建议立刻验证结果：

• 列出所有主题：bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
• 查看主题详情（确认分区/副本）：bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic user-events
• 删除后若主题仍出现在 list 中，说明尚未清理完成，或配置未生效

常见问题与注意事项

实际操作中容易忽略的细节：

• 旧版本 Kafka（如 2.x 之前）依赖 ZooKeeper，命令中需用 --zookeeper 而非 --bootstrap-server；当前主流版本（3.0+）已完全去 ZooKeeper 依赖
• 主题名不区分大小写，但建议统一小写，避免客户端解析异常
• 删除主题时若消费者组仍在消费该主题，Kafka 不阻止删除，但后续消费将失败（无主题）
• 创建时若主题已存在，命令会报错；可加 --if-not-exists 参数静默跳过（Kafka 3.3+ 支持）