Revert back changes

aklivity · Feb 29, 2024 · 7b36c26 · 7b36c26
1 parent cbfc080
commit 7b36c26
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 9 deletions.
diff --git a/...zilla/specs/binding/kafka/streams/network/produce.v3/message.values.sequential/client.rpt b/...zilla/specs/binding/kafka/streams/network/produce.v3/message.values.sequential/client.rpt
@@ -26,11 +26,11 @@ connect "zilla://streams/net0"
 
 connected
 
-write 21                                # size
+write 26                                # size
       3s                                # metadata
       5s                                # v5
       ${newRequestId}
-      -1s                               # no client id
+      5s "zilla"                        # client id
       1                                 # topics
         4s "test"                       #   "test" topic
       [0x00]                            # allow_auto_topic_creation
@@ -74,15 +74,18 @@ write zilla:begin.ext ${proxy:beginEx()
                                  .sourcePort(0)
                                  .destinationPort(9092)
                                  .build()
+                               .info()
+                                 .authority("broker1.example.com")
+                                 .build()
                                .build()}
 
 connected
 
-write 7278
+write 7283
       0s
       3s
       ${newRequestId}
-      -1s
+      5s "zilla"                        # client id
       -1s
       0s                                # acks
       ${produceWaitMax}

diff --git a/...zilla/specs/binding/kafka/streams/network/produce.v3/message.values.sequential/server.rpt b/...zilla/specs/binding/kafka/streams/network/produce.v3/message.values.sequential/server.rpt
@@ -28,11 +28,11 @@ accepted
 
 connected
 
-read 21                                 # size
+read 26                                 # size
      3s                                 # metadata
      5s                                 # v5
      (int:requestId)
-     -1s                                # no client id
+     5s "zilla"                         # client id
      1                                  # topics
      4s "test"                        #   "test" topic
      [0x00]                             # allow_auto_topic_creation
@@ -61,7 +61,7 @@ write 97                                # size
 
 accepted
 
-read zilla:begin.ext ${proxy:beginEx()
+read zilla:begin.ext ${proxy:matchBeginEx()
                               .typeId(zilla:id("proxy"))
                               .addressInet()
                                 .protocol("stream")
@@ -70,15 +70,18 @@ read zilla:begin.ext ${proxy:beginEx()
                                 .sourcePort(0)
                                 .destinationPort(9092)
                                 .build()
+                              .info()
+                                .authority("broker1.example.com")
+                                .build()
                               .build()}
 
 connected
 
-read 7278
+read 7283
      0s
      3s
      (int:requestId)
-     -1s
+     5s "zilla"                         # client id
      -1s
      [0..2]
      [0..4]