@ 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" ; }
Check that a kafka topic exist