code: @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);
      }
docs: Copy Kafka Topic content to file
  
  @param topic_name
  @param filename
  @param header
  @throws Exception