code: @Then("^A kafka topic named '(.+?)' exists")
      public void kafkaTopicExist(String topic_name) throws KeeperException, InterruptedException {
          assert commonspec.getKafkaUtils().getZkUtils().pathExists("/" + topic_name) : "There is no topic with that name";
      }
docs: Check that a kafka topic exist
  
  @param topic_name name of topic