第一种方式：删除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