query: 1.0.6 - Added `QueryApplicationIT`

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / query / TestData.java

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 82f7217..610bca0 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
@@ -42,6 +42,11 @@ class TestData
 
        private static UserRanking userRankingOf(String json)
        {
+               if (json == null)
+               {
+                       return null;
+               }
+
                try
                {
                        return objectMapper.readValue(json, UserRanking.class);