@Test
  public void testFiveStreamProcessors() {
    testStreamProcessor(new String[]{"4", "5", "6", "7", "8"});
  }
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/TestZkStreamProcessor.java