第一种方式:删除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
如果觉得我的文章对你有用,请随意赞赏
扫一扫支付

