public Set<String> getKinesisStreams(String system) {
    // build stream-level configs
    Config streamsConfig = subset(String.format("systems.%s.streams.", system), true);
    // all properties should now start with stream name
    Set<String> streams = new HashSet<>();
    streamsConfig.keySet().forEach(key -> {
      String[] parts = key.split("\\.", 2);
      if (parts.length != 2) {
        throw new IllegalArgumentException("Ill-formatted stream config: " + key);
      }
      streams.add(parts[0]);
    });
    return streams;
  }
Return a set of streams from the config for a given system.
@param system name of the system
@return a set of streams
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java