X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FTestData.java;h=7c713128c8ab00d100b9f37b5bf62680769ae653;hb=9c1b63783704ee2adf031441ad13bfaba65f5969;hp=44162a0d9ab760ca2e9c9a607661f91e99511842;hpb=bcb04c8b890c6b4233835151960cd69b77297af7;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
index 44162a0..7c71312 100644
--- a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
@@ -18,6 +18,7 @@ class TestData
 {
 	static final TestUser PETER = TestUser.of(STATS_TYPE, "peter");
 	static final TestUser KLAUS = TestUser.of(STATS_TYPE, "klaus");
+	static final TestUser OTHER_CHANNEL = TestUser.of("POPULAR", "klaus");
 
 	static final Stream<KeyValue<TestUser, TestRanking>> getTop10Messages()
 	{
@@ -84,6 +85,10 @@ class TestData
 					KLAUS,
 					TestRanking.of(
 							TestEntry.of("Müsch", 1l))),
+			KeyValue.pair( // 1
+					OTHER_CHANNEL,
+					TestRanking.of(
+							TestEntry.of("Müsch", 1l))),
 			KeyValue.pair( // 2
 					PETER,
 					TestRanking.of(
@@ -121,6 +126,11 @@ class TestData
 					TestRanking.of(
 							TestEntry.of("Müsch", 2l),
 							TestEntry.of("s", 2l))),
+			KeyValue.pair( // 8
+					OTHER_CHANNEL,
+					TestRanking.of(
+							TestEntry.of("Müsch", 2l),
+							TestEntry.of("s", 2l))),
 			KeyValue.pair( // 9
 					PETER,
 					TestRanking.of(