消息的过期时间
我们在使用Kafka存储消息时，如果已经消费过了，再永久存储是一种资源的浪费，所有，kafka为我们提供了消息文件的过期策略，可以通过配置server.properies来实现
# vi config/server.properies
修改下面的代码
log.roll.hours=1
log.retention.hours=2
log.segment.delete.delay.ms=0
重启kafka服务即可，上面表示消息存储时间为２小时。
参考文章：https://my.oschina.net/abcfy2/blog/634973