@Override
  public String toString() {
    return "KinesisIncomingMessageEnvelope:: shardId:" + shardId + ", sequenceNumber:" + sequenceNumber
        + ", approximateArrivalTimestamp:" + approximateArrivalTimestamp + ", message:" + getMessage();
  }
Kinesis record with payload and some metadata.
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisIncomingMessageEnvelope.java