Fixing kafka transport to work with latest seneca transport version