- kafkaTemplate.send(TOPIC_IN, mapper.writeValueAsString(recording));
-
- String word1 = mapper.writeValueAsString(Word.of("peter", "Hallo"));
- String word2 = mapper.writeValueAsString(Word.of("peter", "Welt"));
+ kafkaTemplate.send(TOPIC_IN, recording.getUser(), mapper.writeValueAsString(recording));
+ recording.setUser("klaus");
+ recording.setSentence("Müsch gäb's auch!");
+ kafkaTemplate.send(TOPIC_IN, recording.getUser(), mapper.writeValueAsString(recording));
+ recording.setUser("peter");
+ recording.setSentence("Boäh, echt! ß mal nä Nümmäh!");
+ kafkaTemplate.send(TOPIC_IN, recording.getUser(), mapper.writeValueAsString(recording));
+
+ String peter1 = mapper.writeValueAsString(Word.of("peter", "Hallo"));
+ String peter2 = mapper.writeValueAsString(Word.of("peter", "Welt"));
+ String peter3 = mapper.writeValueAsString(Word.of("peter", "Boäh"));
+ String peter4 = mapper.writeValueAsString(Word.of("peter", "echt"));
+ String peter5 = mapper.writeValueAsString(Word.of("peter", "ß"));
+ String peter6 = mapper.writeValueAsString(Word.of("peter", "mal"));
+ String peter7 = mapper.writeValueAsString(Word.of("peter", "nä"));
+ String peter8 = mapper.writeValueAsString(Word.of("peter", "Nümmäh"));
+
+ String klaus1 = mapper.writeValueAsString(Word.of("klaus","Müsch"));
+ String klaus2 = mapper.writeValueAsString(Word.of("klaus","gäb"));
+ String klaus3 = mapper.writeValueAsString(Word.of("klaus","s"));
+ String klaus4 = mapper.writeValueAsString(Word.of("klaus","auch"));