hotfixing kafka intake