WIP

[demos/kafka/wordcount] / query

diff --git a/query b/query
index 0d1ed8c..eb8e65b 160000 (submodule)
--- a/query
+++ b/query
@@ -1 +1 @@
-Subproject commit 0d1ed8c65f422e5c0cd291c35dba67b1f2205997
+Subproject commit eb8e65bb79c99a1e43f5a0d5c58c3367030d20f9