public long getChangelogMinCompactionLagMs(String storeName) {
    String minCompactLagConfigName = String.format(CHANGELOG_MIN_COMPACTION_LAG_MS, storeName);
    // Avoid the inconsistency of overriding using stores.x.changelog.kafka...
    checkArgument(get("stores." + storeName + ".changelog.kafka." + MIN_COMPACTION_LAG_MS) == null,
        "Use " + minCompactLagConfigName + " to set kafka min.compaction.lag.ms property.");

    return getLong(minCompactLagConfigName, getDefaultChangelogMinCompactionLagMs());
  }
Gets the serialized instance of SideInputsProcessor associated with the {@code storeName}.

@param storeName name of the store
@return the serialized instance of SideInputsProcessor if present, empty optional otherwise
samza-core/src/main/java/org/apache/samza/config/StorageConfig.java