@Override
  public byte[] get(byte[] key) {
    return store.get(key);
  }
This class checks for the size of the message being stored and either throws an exception when a large message is
encountered or ignores the large message and continues processing, depending on how it is configured.
samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java