@ When ( "^I copy the kafka topic '(.*?)' to file '(.*?)' with headers '(.*?)'$" ) public void topicToFile ( String topic_name , String filename , String header ) throws Exception { commonspec . getKafkaUtils ( ) . resultsToFile ( topic_name , filename , header ) ; }
Copy Kafka Topic content to file