@Override
  public void register(SystemStreamPartition systemStreamPartition, String s) {
  }
A simple implementation of array system consumer
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemConsumer.java