function emitEofEventsFor(messageIndex) {
      while (currentEofEventsIndex < eofEvents.length && eofEvents[currentEofEventsIndex].messageIndex === messageIndex) {
        delete eofEvents[currentEofEventsIndex].messageIndex;
        self.emit('partition.eof', eofEvents[currentEofEventsIndex])
        ++currentEofEventsIndex;
      }
    }
Consume a number of messages and wrap in a try catch with
proper error reporting. Should not be called directly,
and instead should be called using consume.

@private
@see consume