public boolean isEndOfStream() {
    return END_OF_STREAM_OFFSET.equals(offset);
  }
Offset associated with this message, provided by the system consumer that consumed the message.
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java