Initial implementation of kafka topics