First time running the dcl when I start a job it seems to rarely get to the dcl. Not sure if this is a kafka issue