Spark Streaming从kafka中读取数据导致OOM

我通过Spark Streaming从Kafka中读取数据的时候遇到这么一个问题，如果我总是读取最新的数据，程序能够正常跑，但是如果我的程序停止过一段时间，程序重新启动之后，为防止数据丢失，从老数据那里读，因为streaming是根据时间段来读取数据，这样一秒内就会把所有的已有数据读进来，当做一个rdd。这样数据太多，会导致程序的oom。这种应该怎么控制呢？求大神帮忙。谢谢啦。