| 工具 | bin/kafka-topics.sh（部分发行版为 kafka-topics） |
|---|---|
| 必填 | --bootstrap-server、--create、--topic |
| 常用 | --partitions、--replication-factor、--config、--if-not-exists |
创建主题
创建主题
kafka-topics.sh --bootstrap-server broker1:9092 \
--create --topic orders \
--partitions 6 --replication-factor 3 \
--config retention.ms=604800000 \
--config min.insync.replicas=2
kafka-topics.sh --bootstrap-server broker1:9092 \
--create --topic orders --if-not-exists \
--partitions 6 --replication-factor 3副本因子不能超过 Broker 数量，超过会直接报错；跨机房集群要确认机架感知配置。