diff --git a/students/src/main/java/ee/ut/cs/dsg/PeopleProducer.java b/students/src/main/java/ee/ut/cs/dsg/PeopleProducer.java index c8f58fa..16d23a3 100644 --- a/students/src/main/java/ee/ut/cs/dsg/PeopleProducer.java +++ b/students/src/main/java/ee/ut/cs/dsg/PeopleProducer.java @@ -33,8 +33,8 @@ public void createProducer() throws InterruptedException, FileNotFoundException KafkaProducer observer = new KafkaProducer<>(props); long ts = 0; - - File file = new File(PeopleProducer.class.getClassLoader().getResource("people.csv").getPath()); + + File file = new File(PeopleProducer.class.getClassLoader().getResource("people.csv").getPath().replace("%20", " ")); FileReader f = new FileReader(file); CSVReader reader = new CSVReader(f);