WIP

[demos/kafka/wordcount] / query

diff --git a/query b/query
index 99ed5d0..3e27e5d 160000 (submodule)
--- a/query
+++ b/query
@@ -1 +1 @@
-Subproject commit 99ed5d04aa6d0bd08470d98586c7c4a635149297
+Subproject commit 3e27e5d91b4920ffd3cd061595329b5499c3389f