消息的過期時間
我們在使用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