popular: 1.1.1 - Refined output JSON
[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / popular / TestData.java
index fa6a258..4ac9fd4 100644 (file)
@@ -192,7 +192,7 @@ class TestData
 
                windowedWord.setStart(ZonedDateTime.ofInstant(outputWindowedWord.getStart(), CLOCK.getZone()));
                windowedWord.setEnd(ZonedDateTime.ofInstant(outputWindowedWord.getEnd(), CLOCK.getZone()));
-               windowedWord.setWord(outputWindowedWord.getWord());
+               windowedWord.setKey(outputWindowedWord.getKey());
 
                return windowedWord;
        }
@@ -211,7 +211,7 @@ class TestData
                        WordCounter counter)
        {
                OutputWordCounter outputWordCounter = OutputWordCounter.of(
-                               word.getWord(),
+                               word.getKey(),
                                counter.getCounter());
                assertWordCountEqualsWordCountFromLastMessage(word, outputWordCounter);
        }