Kafka starts! and refactored code to be class based