Cleans up consumer transports and adds kafka transport boilerplate.