public boolean hasDurableStores() {
    Config subConfig = subset(STORE_PREFIX, true);
    return subConfig.keySet().stream().anyMatch(key -> key.endsWith(CHANGELOG_SUFFIX));
  }
Helper method to check if there is any stores configured w/ a changelog
samza-core/src/main/java/org/apache/samza/config/StorageConfig.java