Each consumer reads in a go block. Ack early.