public class KafkaUtil extends Object
public static String getEventFilePath(String sampleNumber, String topic, String filePath) throws Exception
sampleNumber
- Number of the sample which is running currentlytopic
- topic of the message to be sent (the data file should be named with the topic)filePath
- file path if a sample if not runningException
Copyright © 2016 WSO2 Inc. All rights reserved.