@Before
  @Override
  public void setUp() {
    super.setUp();
    producer = new KafkaProducer<>(createProducerConfigs());
    consumer = new KafkaConsumer<>(createConsumerConfigs());

    Properties kafkaConfig = new Properties();
    kafkaConfig.setProperty(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers());
    adminClient = AdminClient.create(kafkaConfig);

    systemAdmin = createSystemAdmin("kafka");
    systemAdmin.start();
  }
Starts a single kafka broker, and a single embedded zookeeper server in their own threads.
Sub-classes should invoke {@link #zkConnect()} and {@link #bootstrapUrl()}s to
obtain the urls (and ports) of the started zookeeper and kafka broker.
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java