query: 1.0.6 - Added `QueryStreamProcessorTopologyTest`
authorKai Moritz <kai@juplo.de>
Sun, 9 Jun 2024 10:09:49 +0000 (12:09 +0200)
committerKai Moritz <kai@juplo.de>
Tue, 11 Jun 2024 17:16:30 +0000 (19:16 +0200)
commit213321a01c3b53f86eb2dd97c3f6241e9cad9045
tree6ff802e79c63f547327b20c9b4272a6ddf91c20d
parent030c0db664cea0ec3e4307065054c449dbca6be2
query: 1.0.6 - Added `QueryStreamProcessorTopologyTest`
pom.xml
src/main/java/de/juplo/kafka/wordcount/query/Entry.java
src/main/java/de/juplo/kafka/wordcount/query/Key.java
src/main/java/de/juplo/kafka/wordcount/query/UserRanking.java
src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/query/TestData.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/top10/TestEntry.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/top10/TestRanking.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/users/TestUserData.java [new file with mode: 0644]