第一种方式:删除topic,慎重

bin/kafka-topics.sh --delete --topic flink-kafka-test --zookeeper 127.0.0.1:2181


第一种方式:设置topic保存时间 retention

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

 

最后修改于 2021-10-21 16:35:08
如果觉得我的文章对你有用,请随意赞赏
扫一扫支付
上一篇