each TopicAndPartition checkpoints to its own Kafka topic
Merge pull request #91 from manuzhang/at_least_once

fix creating checkpoint topic conflicts