您已经问过这个问题,我已经在这里回答:使用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)
| 归档时间: |
|
| 查看次数: |
3431 次 |
| 最近记录: |