KafkaCheckpointMgr should use KafkaSystemFactory to instantiate systemConsumer and systemProducer

Currently KafkaCheckpointMgr is using SimpleKafkaConsumer directly to read the the checkpoint stream. Instead it should use a factory, so another factory can be plugged in if needed.