Could you peek ahead and try to detect the invalid group (as per the original post in this thread), then force a commit using a completion policy and deal with marking incomplete groups in a listener, or possible the writer. Then the next chunk will start with the peeked item (which you know is part of the next group)?
Or you could do the group validation as a completely separate step?


Reply With Quote
