reverting kafka reader as default
adding taskId to info, so the part-* file can be located