为Kafka中的特定主题更改TTL

Sat*_*Sat 4 apache-kafka

更新主题的TTL,以便记录在主题中保留10天。仅针对此主题执行此操作。保留所有其他主题TTL相同的当前配置

ppa*_*rno 8

您已经问过这个问题,我已经在这里回答:使用Java更新kafka中特定主题的TTL

或者,也许您是要使用Kafka工具而不是Java来做到这一点?在这种情况下,可以使用--alter选项使用kafka-topics.sh命令行工具进行此操作。

bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic test --config retention.ms=10000
Run Code Online (Sandbox Code Playgroud)

由于在下一版本中可以删除使用kafka-topics脚本进行的更改,因此您应该使用kafka-configs脚本:

bin/kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --entity-name test --add-config retention.ms=5000
Run Code Online (Sandbox Code Playgroud)