Refactored Kafka receiver logic and Kafka testsuites
Merge pull request #5 from tdas/kafka-refactor

Refactored Kafka receiver logic and Kafka testsuites