periodically checkpoint messages and timestamp to Kafka
Merge pull request #81 from manuzhang/at_least_once

periodically checkpoint messages and timestamp to Kafka