Refactor the kafka interactions so the endpoint needs to know a lot less
Integrate start of lifecycle into factories