Change stream to duplex

aklivity · May 27, 2024 · c833fb8 · c833fb8
1 parent 68d6886
commit c833fb8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/...g/kafka/streams/application/merged/merged.produce.and.fetch.get.cleanup.policy/client.rpt b/...g/kafka/streams/application/merged/merged.produce.and.fetch.get.cleanup.policy/client.rpt
@@ -16,7 +16,7 @@
 
 connect "zilla://streams/app0"
     option zilla:window 16
-    option zilla:transmission "half-duplex"
+    option zilla:transmission "duplex"
 
 write zilla:begin.ext ${kafka:beginEx()
                                .typeId(zilla:id("kafka"))
@@ -30,4 +30,13 @@ write zilla:begin.ext ${kafka:beginEx()
                                    .build()
                                .build()}
 
+read zilla:begin.ext ${kafka:beginEx()
+                               .typeId(zilla:id("kafka"))
+                               .merged()
+                                    .capabilities("PRODUCE_AND_FETCH")
+                                    .topic("test")
+                                    .config("cleanup.policy", "compact")
+                                   .build()
+                               .build()}
+
 connected
diff --git a/...g/kafka/streams/application/merged/merged.produce.and.fetch.get.cleanup.policy/server.rpt b/...g/kafka/streams/application/merged/merged.produce.and.fetch.get.cleanup.policy/server.rpt
@@ -19,7 +19,7 @@ property newTimestamp ${kafka:timestamp() + deltaMillis}
 
 accept "zilla://streams/app0"
     option zilla:window 8192
-    option zilla:transmission "half-duplex"
+    option zilla:transmission "duplex"
 
 accepted