Added embedded Kafka to help with unit testing