Now working with kafka