@Override
  public void init(Context context) throws Exception {
    maxMessages = context.getJobContext().getConfig().getInt("task.max.messages", 50);
    String outputSystemStreamString = context.getJobContext().getConfig().get("task.outputs", null);
    if (outputSystemStreamString == null) {
      throw new ConfigException("Missing required configuration: task.outputs");
    }
    outputSystemStream = StreamUtil.getSystemStreamFromNames(outputSystemStreamString);
  }
The SystemStream to send negated numbers to.
samza-test/src/main/java/org/apache/samza/test/integration/NegateNumberTask.java