Kafka 0.10.0.2.6清理主题后如何恢复原日志保留时间？

首先直接给你明确结论：你提到的命令kafka-topics --zookeeper <zookeeper_address> --alter --topic <topic_name> --delete-config retention.ms完全适用于Kafka 0.10.0.2.6版本。这个版本已经支持通过--delete-config参数移除主题级别的自定义配置，让主题重新继承全局的Broker配置。

接下来，针对你要恢复所有主题到原始全局配置（log.retention.hours=168）的需求，分步骤说明：

1. 批量恢复所有主题的配置 #

因为你有多个主题，手动逐个执行命令效率太低，推荐用脚本批量处理：

Shell脚本批量处理方案 #

在ZooKeeper或任意能访问Kafka命令行的节点上，执行以下脚本：

# 定义ZooKeeper地址，根据你的实际环境修改
ZK_ADDR="localhost:2181"
# 定义Kafka命令路径（匹配你的HDP环境路径）
KAFKA_TOPICS_CMD="/usr/hdp/2.6.0.3-8/kafka/bin/kafka-topics.sh"

# 遍历所有主题，执行删除自定义配置命令
$KAFKA_TOPICS_CMD --list --zookeeper $ZK_ADDR | while read topic; do
  echo "正在恢复主题 $topic 的配置..."
  $KAFKA_TOPICS_CMD --zookeeper $ZK_ADDR --alter --topic $topic --delete-config retention.ms
done

这个脚本会自动读取所有主题（包括内部主题__consumer_offsets和_schemas），逐一移除它们的retention.ms自定义配置，让主题重新继承全局的日志保留策略。

2. 验证恢复是否成功 #

执行完脚本后，你可以通过以下方式验证配置是否生效：

单个主题验证 #

替换为你要检查的主题名，执行命令：

$KAFKA_TOPICS_CMD --describe --zookeeper localhost:2181 --topic hrtfsa.polr.mdr.initial

在输出的Configs:部分，如果看不到retention.ms的配置项，说明该主题已经成功继承全局的log.retention.hours=168配置。

批量验证所有主题 #

用以下命令快速查看所有主题的配置状态：

$KAFKA_TOPICS_CMD --list --zookeeper localhost:2181 | while read topic; do
  echo "=== 主题 $topic 配置信息 ==="
  $KAFKA_TOPICS_CMD --describe --zookeeper localhost:2181 --topic $topic | grep -E "Topic:|Configs:"
  echo ""
done

额外注意事项 #

• 内部主题__consumer_offsets：这个主题存储消费者偏移量，清理后恢复配置很有必要，避免后续消费者偏移量被过早清理导致消费异常。
• 全局配置优先级：当主题没有自定义的retention.ms配置时，Kafka会自动使用Broker的log.retention.hours配置（你的环境是168小时/7天），无需额外设置主题的retention.hours参数。

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