AWS MSK主题数据保留策略未按预期生效问题排查

我拥有一个配置了以下自定义集群参数的AWS MSK集群：

auto.create.topics.enable=true
default.replication.factor=3
min.insync.replicas=2
num.partitions=9
log.retention.ms=172800000
log.cleanup.policy=delete

我使用启用了Kafka Connect库的EC2作为客户端，MSK集群运行正常。但执行以下命令检查主题test-retention-check的数据保留策略时，仅输出一行内容：

./kafka-configs.sh \
  --bootstrap-server '' \
  --entity-type topics \
  --entity-name test-retention-check \
  --describe \
  --command-config ../config/client.properties

输出：

Dynamic configs for topic test-retention-check are:

创建新主题后执行该命令仍得到相同结果。即使未手动配置，也应显示默认的7天保留期，但实际未显示，请问问题出在哪里？

• kafka-configs.sh的输出逻辑限制：这个命令默认只展示针对主题单独设置的动态覆盖配置，不会显示从集群继承的默认参数。你的输出为空，说明目标主题没有任何自定义的主题级配置，完全使用集群默认值。

• 查看实际生效的主题配置：要获取主题实际生效的完整配置（包括继承的集群默认），请使用kafka-topics.sh的--describe命令：

./kafka-topics.sh \
  --bootstrap-server '' \
  --topic test-retention-check \
  --describe \
  --command-config ../config/client.properties

执行后，输出中的RetentionMs字段就是该主题实际使用的保留时长，会匹配你在集群参数中设置的172800000（2天），而非Kafka原生的7天默认值。

• 验证集群默认配置的生效情况：你已经在集群级别设置了log.retention.ms=172800000，所有未单独配置保留策略的主题都会继承这个值，因此不会出现7天的原生默认值。

内容的提问来源于stack exchange，提问作者RushHour