tests for PartitionManager

require creation of an instance of KafkaUtils (to decouple for unit testing)
refactor classes that use KafkaUtils
write some tests for PartitionManager