private void createTopics(String inputTopic, String outputTopic) {
    TestUtils.createTopic(kafkaZkClient(), inputTopic, 1, 1, servers(), new Properties());
    TestUtils.createTopic(kafkaZkClient(), outputTopic, 1, 1, servers(), new Properties());
  }
Should fail to create a SamzaContainer when neither task factory nor task.class are provided.
samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java