@Before
  public void setup() {
    PROCESSED.clear();
  }
If message equals this string, then shut down the task.
samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java