@Override
  public void put(byte[] key, byte[] value) {
    validateMessageSize(value);
    if (!isLargeMessage(value)) {
      store.put(key, value);
    } else {
      LOG.info("Ignoring a large message with size " + value.length + " since it is greater than "
          + "the maximum allowed value of " + maxMessageSize);
      largeMessageSafeStoreMetrics.ignoredLargeMessages().inc();
    }
  }
This function puts a message in the store after validating its size.
It drops the large message if it has been configured to do so.
Otherwise, it throws an exception stating that a large message was encountered.

@param key the key with which the specified {@code value} is to be associated.
@param value the value with which the specified {@code key} is to be associated.
samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java