@Override
  protected void serviceStart() throws Exception {
    serverStartable.startup();
    log.info("Kafka Server Started on port {}", brokerPort);

  }
This class has the hooks to start and stop single node kafka cluster.
itests/qtest-druid/src/main/java/org/apache/hive/kafka/SingleNodeKafkaCluster.java