kafka-topics

Kafka 主题创建与运维

补充说明

kafka-topics 创建、查看、修改和删除 Kafka 主题，管理分区、副本和主题级配置。它是 Kafka 自带脚本，需要连接 bootstrap server。

常用示例

kafka-topics --bootstrap-server broker1:9092 --list
kafka-topics --bootstrap-server broker1:9092 \
  --create --topic app-events --partitions 6 --replication-factor 3
kafka-topics --bootstrap-server broker1:9092 --describe --topic app-events
kafka-topics --bootstrap-server broker1:9092 \
  --alter --topic app-events --partitions 12
kafka-topics --bootstrap-server broker1:9092 \
  --alter --topic app-events --config min.insync.replicas=2
kafka-topics --bootstrap-server broker1:9092 --delete --topic app-events

易错点与排错

• 副本因子不能超过 broker 数量；单节点测试只能用 1。
• 分区只能增加，不能减少；扩分区会改变 key 的路由，评估业务影响。
• 删除主题需要 broker 开启 delete.topic.enable；否则只是标记删除。
• --bootstrap-server 只需一个可达地址，客户端会自动发现集群。
• 副本因子和 min.insync.replicas 共同影响写入可用性。
• 分区增加后，已有 key 的分区映射会变化；依赖顺序的场景要谨慎。
• 跨机房/多副本部署要确认 rack awareness 和副本分布。
• 主题名和配置变更要通过变更流程；不要在生产随意改分区。

相关命令

• kcat — 生产消费与调试
• kafka-consumer-groups — 消费组与 lag
• kafka-configs — 主题配置