considering the research done in #72 implement the necessary changes using Kafka as the event log
considering the research done in #72 implement the necessary changes using Kafka as the event log