- kafkaTemplate.send(TOPIC_IN, "peter", "Hallo");
- kafkaTemplate.send(TOPIC_IN, "klaus", "Müsch");
- kafkaTemplate.send(TOPIC_IN, "peter", "Welt");
- kafkaTemplate.send(TOPIC_IN, "klaus", "Müsch");
- kafkaTemplate.send(TOPIC_IN, "klaus", "s");
- kafkaTemplate.send(TOPIC_IN, "peter", "Boäh");
- kafkaTemplate.send(TOPIC_IN, "peter", "Welt");
- kafkaTemplate.send(TOPIC_IN, "peter", "Boäh");
- kafkaTemplate.send(TOPIC_IN, "klaus", "s");
- kafkaTemplate.send(TOPIC_IN, "peter", "Boäh");
- kafkaTemplate.send(TOPIC_IN, "klaus", "s");
-
- Message peter1 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Hallo\"}",
- "1");
- Message peter2 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Welt\"}",
- "1");
- Message peter3 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "1");
- Message peter4 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Welt\"}",
- "2");
- Message peter5 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "2");
- Message peter6 = Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "3");
-
- Message klaus1 = Message.of(
- "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
- "1");
- Message klaus2 = Message.of(
- "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
- "2");
- Message klaus3 = Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "1");
- Message klaus4 = Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "2");
- Message klaus5 = Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "3");
-
- await("Expexted converted data")