code: @Given("^I connect to kafka at '(.+)' using path '(.+)'$")
      public void connectKafka(String zkHost, String zkPath) throws UnknownHostException {
          String zkPort = zkHost.split(":")[1];
          zkHost = zkHost.split(":")[0];
          commonspec.getKafkaUtils().setZkHost(zkHost, zkPort, zkPath);
          commonspec.getKafkaUtils().connect();
      }
docs: Connect to Kafka.
  
  @param zkHost ZK host
  @param zkPath ZK port
  @throws UnknownHostException exception