@Override
    public Map<String, SystemStreamMetadata> getSystemStreamMetadata(Set<String> streamNames) {
      return streamNames.stream()
              .collect(Collectors.toMap(Function.identity(), streamName -> new SystemStreamMetadata(streamName,
                      Collections.singletonMap(new Partition(0),
                              new SystemStreamMetadata.SystemStreamPartitionMetadata(null, null, null)))));
    }
System factory of Samza Sql Shell which needs to provide Consumer, Producer and Admin
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliLoggingSystemFactory.java