diff --git a/internal/test_helpers/fixtures/base/pass b/internal/test_helpers/fixtures/base/pass index ee6d962..bc86f62 100644 --- a/internal/test_helpers/fixtures/base/pass +++ b/internal/test_helpers/fixtures/base/pass @@ -19,7 +19,7 @@ Debug = true [stage-10] Hexdump of received "Fetch" response:  [stage-10] Idx | Hex | ASCII [stage-10] -----+-------------------------------------------------+----------------- -[stage-10] 0000 | 0a 95 c1 bf 00 00 00 00 00 00 00 09 fb d5 3f 02 | ..............?. +[stage-10] 0000 | 0a 95 c1 bf 00 00 00 00 00 00 00 0b c4 43 93 02 | .............C.. [stage-10] 0010 | 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 01 | ................ [stage-10] 0020 | 02 00 00 00 00 00 64 ff ff ff ff ff ff ff ff ff | ......d......... [stage-10] 0030 | ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff 01 | ................ @@ -31,7 +31,7 @@ Debug = true [stage-10] [Decoder] - .ResponseBody [stage-10] [Decoder]  ✔️ .throttle_time_ms (0) [stage-10] [Decoder]  ✔️ .error_code (0) -[stage-10] [Decoder]  ✔️ .session_id (167499071) +[stage-10] [Decoder]  ✔️ .session_id (197411731) [stage-10] [Decoder]  ✔️ .num_responses (1) [stage-10] [Decoder]  - .TopicResponse[0] [stage-10] [Decoder]  ✔️ .topic_id (00000000-0000-0000-0000-000000000001) @@ -73,7 +73,7 @@ Debug = true [stage-9] Hexdump of received "Fetch" response:  [stage-9] Idx | Hex | ASCII [stage-9] -----+-------------------------------------------------+----------------- -[stage-9] 0000 | 60 5a 05 cd 00 00 00 00 00 00 00 18 fb 19 ff 01 | `Z.............. +[stage-9] 0000 | 60 5a 05 cd 00 00 00 00 00 00 00 1a 65 09 47 01 | `Z..........e.G. [stage-9] 0010 | 00 | . [stage-9]  [stage-9] [Decoder] - .ResponseHeader @@ -82,7 +82,7 @@ Debug = true [stage-9] [Decoder] - .ResponseBody [stage-9] [Decoder]  ✔️ .throttle_time_ms (0) [stage-9] [Decoder]  ✔️ .error_code (0) -[stage-9] [Decoder]  ✔️ .session_id (419109375) +[stage-9] [Decoder]  ✔️ .session_id (442829127) [stage-9] [Decoder]  ✔️ .num_responses (0) [stage-9] [Decoder]  ✔️ .TAG_BUFFER [stage-9] ✓ Correlation ID: 1616512461 @@ -138,7 +138,7 @@ Debug = true [stage-8] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-8] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-8] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-8] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-8] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-8] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-8] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-8]  @@ -519,7 +519,7 @@ Debug = true [stage-7] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-7] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-7] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-7] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-7] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-7] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-7] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-7]  @@ -874,7 +874,7 @@ Debug = true [stage-7] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-7] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-7] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-7] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-7] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-7] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-7] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-7]  @@ -1245,7 +1245,7 @@ Debug = true [stage-6] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-6] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-6] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-6] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-6] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-6] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-6] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-6]  @@ -1608,7 +1608,7 @@ Debug = true [stage-6] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-6] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-6] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-6] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-6] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-6] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-6] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-6]  @@ -1979,7 +1979,7 @@ Debug = true [stage-5] 01c0 | 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 0e 6b 72 | .version......kr [stage-5] 01d0 | 61 66 74 2e 76 65 72 73 69 6f 6e 00 00 00 01 00 | aft.version..... [stage-5] 01e0 | 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f | .metadata.versio -[stage-5] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 87 | n............... +[stage-5] 01f0 | 6e 00 01 00 16 00 01 08 00 00 00 00 00 00 00 9a | n............... [stage-5] 0200 | 02 17 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 | ....metadata.ver [stage-5] 0210 | 73 69 6f 6e 00 14 00 14 00 | sion..... [stage-5]  @@ -2336,18 +2336,18 @@ Debug = true [stage-3] $ ./your_program.sh [stage-3] Connecting to broker at: localhost:9092 [stage-3] Connection to broker at localhost:9092 successful -[stage-3] Sending "ApiVersions" (version: 3) request (Correlation id: 1952128842) +[stage-3] Sending "ApiVersions" (version: 4) request (Correlation id: 1952128842) [stage-3] Hexdump of sent "ApiVersions" request:  [stage-3] Idx | Hex | ASCII [stage-3] -----+-------------------------------------------------+----------------- -[stage-3] 0000 | 00 00 00 23 00 12 00 03 74 5b 1f 4a 00 09 6b 61 | ...#....t[.J..ka +[stage-3] 0000 | 00 00 00 23 00 12 00 04 74 5b 1f 4a 00 09 6b 61 | ...#....t[.J..ka [stage-3] 0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-c [stage-3] 0020 | 6c 69 04 30 2e 31 00 | li.0.1. [stage-3]  [stage-3] Hexdump of received "ApiVersions" response:  [stage-3] Idx | Hex | ASCII [stage-3] -----+-------------------------------------------------+----------------- -[stage-3] 0000 | 00 00 01 f3 74 5b 1f 4a 00 00 3e 00 00 00 00 00 | ....t[.J..>..... +[stage-3] 0000 | 00 00 02 19 74 5b 1f 4a 00 00 3e 00 00 00 00 00 | ....t[.J..>..... [stage-3] 0010 | 0b 00 00 01 00 00 00 11 00 00 02 00 00 00 09 00 | ................ [stage-3] 0020 | 00 03 00 00 00 0c 00 00 08 00 00 00 09 00 00 09 | ................ [stage-3] 0030 | 00 00 00 09 00 00 0a 00 00 00 06 00 00 0b 00 00 | ................ @@ -2374,14 +2374,16 @@ Debug = true [stage-3] 0180 | 00 00 00 00 00 00 42 00 00 00 01 00 00 44 00 00 | ......B......D.. [stage-3] 0190 | 00 00 00 00 45 00 00 00 00 00 00 4a 00 00 00 00 | ....E......J.... [stage-3] 01a0 | 00 00 4b 00 00 00 00 00 00 50 00 00 00 00 00 00 | ..K......P...... -[stage-3] 01b0 | 51 00 00 00 00 00 00 00 00 00 03 00 17 02 11 6d | Q..............m -[stage-3] 01c0 | 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f 6e 00 | etadata.version. -[stage-3] 01d0 | 01 00 16 00 01 08 00 00 00 00 00 00 00 92 02 17 | ................ -[stage-3] 01e0 | 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 | ..metadata.versi -[stage-3] 01f0 | 6f 6e 00 14 00 14 00 | on..... +[stage-3] 01b0 | 51 00 00 00 00 00 00 00 00 00 03 00 3d 04 0e 67 | Q...........=..g +[stage-3] 01c0 | 72 6f 75 70 2e 76 65 72 73 69 6f 6e 00 00 00 01 | roup.version.... +[stage-3] 01d0 | 00 0e 6b 72 61 66 74 2e 76 65 72 73 69 6f 6e 00 | ..kraft.version. +[stage-3] 01e0 | 00 00 01 00 11 6d 65 74 61 64 61 74 61 2e 76 65 | .....metadata.ve +[stage-3] 01f0 | 72 73 69 6f 6e 00 01 00 16 00 01 08 00 00 00 00 | rsion........... +[stage-3] 0200 | 00 00 00 a4 02 17 02 11 6d 65 74 61 64 61 74 61 | ........metadata +[stage-3] 0210 | 2e 76 65 72 73 69 6f 6e 00 14 00 14 00 | .version..... [stage-3]  [stage-3] [Decoder] - .Response -[stage-3] [Decoder]  ✔️ .message_length (499) +[stage-3] [Decoder]  ✔️ .message_length (537) [stage-3] [Decoder] - .ResponseHeader [stage-3] [Decoder]  ✔️ .correlation_id (1952128842) [stage-3] ✓ Correlation ID: 1952128842 @@ -2393,18 +2395,18 @@ Debug = true [stage-2] $ ./your_program.sh [stage-2] Connecting to broker at: localhost:9092 [stage-2] Connection to broker at localhost:9092 successful -[stage-2] Sending "ApiVersions" (version: 3) request (Correlation id: 7) +[stage-2] Sending "ApiVersions" (version: 4) request (Correlation id: 7) [stage-2] Hexdump of sent "ApiVersions" request:  [stage-2] Idx | Hex | ASCII [stage-2] -----+-------------------------------------------------+----------------- -[stage-2] 0000 | 00 00 00 23 00 12 00 03 00 00 00 07 00 09 6b 61 | ...#..........ka +[stage-2] 0000 | 00 00 00 23 00 12 00 04 00 00 00 07 00 09 6b 61 | ...#..........ka [stage-2] 0010 | 66 6b 61 2d 63 6c 69 00 0a 6b 61 66 6b 61 2d 63 | fka-cli..kafka-c [stage-2] 0020 | 6c 69 04 30 2e 31 00 | li.0.1. [stage-2]  [stage-2] Hexdump of received "ApiVersions" response:  [stage-2] Idx | Hex | ASCII [stage-2] -----+-------------------------------------------------+----------------- -[stage-2] 0000 | 00 00 01 f3 00 00 00 07 00 00 3e 00 00 00 00 00 | ..........>..... +[stage-2] 0000 | 00 00 02 19 00 00 00 07 00 00 3e 00 00 00 00 00 | ..........>..... [stage-2] 0010 | 0b 00 00 01 00 00 00 11 00 00 02 00 00 00 09 00 | ................ [stage-2] 0020 | 00 03 00 00 00 0c 00 00 08 00 00 00 09 00 00 09 | ................ [stage-2] 0030 | 00 00 00 09 00 00 0a 00 00 00 06 00 00 0b 00 00 | ................ @@ -2431,14 +2433,16 @@ Debug = true [stage-2] 0180 | 00 00 00 00 00 00 42 00 00 00 01 00 00 44 00 00 | ......B......D.. [stage-2] 0190 | 00 00 00 00 45 00 00 00 00 00 00 4a 00 00 00 00 | ....E......J.... [stage-2] 01a0 | 00 00 4b 00 00 00 00 00 00 50 00 00 00 00 00 00 | ..K......P...... -[stage-2] 01b0 | 51 00 00 00 00 00 00 00 00 00 03 00 17 02 11 6d | Q..............m -[stage-2] 01c0 | 65 74 61 64 61 74 61 2e 76 65 72 73 69 6f 6e 00 | etadata.version. -[stage-2] 01d0 | 01 00 16 00 01 08 00 00 00 00 00 00 00 92 02 17 | ................ -[stage-2] 01e0 | 02 11 6d 65 74 61 64 61 74 61 2e 76 65 72 73 69 | ..metadata.versi -[stage-2] 01f0 | 6f 6e 00 14 00 14 00 | on..... +[stage-2] 01b0 | 51 00 00 00 00 00 00 00 00 00 03 00 3d 04 0e 67 | Q...........=..g +[stage-2] 01c0 | 72 6f 75 70 2e 76 65 72 73 69 6f 6e 00 00 00 01 | roup.version.... +[stage-2] 01d0 | 00 0e 6b 72 61 66 74 2e 76 65 72 73 69 6f 6e 00 | ..kraft.version. +[stage-2] 01e0 | 00 00 01 00 11 6d 65 74 61 64 61 74 61 2e 76 65 | .....metadata.ve +[stage-2] 01f0 | 72 73 69 6f 6e 00 01 00 16 00 01 08 00 00 00 00 | rsion........... +[stage-2] 0200 | 00 00 00 a5 02 17 02 11 6d 65 74 61 64 61 74 61 | ........metadata +[stage-2] 0210 | 2e 76 65 72 73 69 6f 6e 00 14 00 14 00 | .version..... [stage-2]  [stage-2] [Decoder] - .Response -[stage-2] [Decoder]  ✔️ .message_length (499) +[stage-2] [Decoder]  ✔️ .message_length (537) [stage-2] [Decoder] - .ResponseHeader [stage-2] [Decoder]  ✔️ .correlation_id (7) [stage-2] ✓ Correlation ID: 7