tests for PartitionManager

refactor KafkaUtils - require creation of an instance to decouple for unit testing
refactor classes that use KafkaUtils
tests for PartitionManager