each TopicAndPartition checkpoints to its own Kafka topic