@ 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 ( ) ; }
Connect to Kafka .