apache-kafka - 如何更改 Kafka 中特定主题的 TTL

Question

我想将特定 Kafka 主题的 TTL 更新为 10 天。
我怎样才能做到这一点？

Answer 1

你之前问过这个问题，我已经在这里回复了:Update TTL for a particular topic in kafka using Java
除非您要求使用 Kafka 工具来做到这一点？ (而不是在 Java 中)
在这种情况下，有 kafka-topics.sh 命令行工具，允许您使用 --alter 选项执行此操作。

bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic test --config retention.ms=10000

因为在下一个版本中可能会删除使用 kafka-topics 脚本的更改，所以您应该使用 kafka-configs 脚本:

bin/kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --entity-name test --add-config retention.ms=5000