public void testSingleStreamProcessor() {
    testStreamProcessorWithSessionRestart(new String[]{"1"});
  }
Happy path tests.
Start 1, 2, 5 processors and make sure they all consume all the events.
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java