private void initConsumer(String bootstrapServer) {
      consumer = TestUtils.createConsumer(
          bootstrapServer,
          "group",
          "earliest",
          true,
          false,
          500,
          SecurityProtocol.PLAINTEXT,
          Option$.MODULE$.<File>empty(),
          Option$.MODULE$.<Properties>empty(),
          new StringDeserializer(),
          new ByteArrayDeserializer());
    }
A wrapper class to consolidate all the components required to be either mocked or stubbed prior to unit testing
the stream processor.
samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java