private static Object[] getArrayObjects(String stream, Config config) {
    try {
      return Base64Serializer.deserialize(config.get("streams." + stream + ".source"), Object[].class);
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }
A simple implementation of array system consumer
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemConsumer.java