| 组成 | 名称 + 分区数 + 副本因子 + 主题级配置 |
|---|---|
| 命名 | 业务域/环境/实体,避免与内部主题冲突 |
| 配置示例 | retention.ms、cleanup.policy、max.message.bytes、min.insync.replicas |
主题级配置查询与修改
主题级配置查询与修改
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics --entity-name orders --describe
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics --entity-name orders \
--alter --add-config retention.ms=259200000
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics --entity-name orders \
--alter --delete-config retention.ms内部主题(__consumer_offsets、__transaction_state)不要手工改配置,交由集群参数管理。