diff --git a/internal/test_helpers/fixtures/fetch/pass b/internal/test_helpers/fixtures/fetch/pass index 0cee0aa..c7c48f9 100644 --- a/internal/test_helpers/fixtures/fetch/pass +++ b/internal/test_helpers/fixtures/fetch/pass @@ -381,13 +381,13 @@ Debug = true [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/.kafka_cleanshutdown [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/partition.metadata [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/partition.metadata -[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/partition.metadata -[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/partition.metadata +[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/partition.metadata +[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/partition.metadata [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/partition.metadata [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/00000000000000000000.log [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/00000000000000000000.log -[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/00000000000000000000.log -[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/00000000000000000000.log +[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/00000000000000000000.log +[stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/00000000000000000000.log [stage-5] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/00000000000000000000.log [stage-5] [Serializer] Finished writing log files to: /tmp/kraft-combined-logs [stage-5] Connecting to broker at: localhost:9092 @@ -404,7 +404,7 @@ Debug = true [stage-5] Hexdump of received "Fetch" response:  [stage-5] Idx | Hex | ASCII [stage-5] -----+-------------------------------------------------+----------------- -[stage-5] 0000 | 60 5a 05 cd 00 00 00 00 00 00 00 0f 32 04 12 01 | `Z..........2... +[stage-5] 0000 | 60 5a 05 cd 00 00 00 00 00 00 00 07 a5 ef 2e 01 | `Z.............. [stage-5] 0010 | 00 | . [stage-5]  [stage-5] [Decoder] - .ResponseHeader @@ -413,7 +413,7 @@ Debug = true [stage-5] [Decoder] - .ResponseBody [stage-5] [Decoder]  - .throttle_time_ms (0) [stage-5] [Decoder]  - .error_code (0) -[stage-5] [Decoder]  - .session_id (254936082) +[stage-5] [Decoder]  - .session_id (128315182) [stage-5] [Decoder]  - .num_responses (0) [stage-5] [Decoder]  - .TAG_BUFFER [stage-5] ✓ Correlation ID: 1616512461 @@ -432,13 +432,13 @@ Debug = true [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/.kafka_cleanshutdown [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/partition.metadata [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/partition.metadata -[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/partition.metadata -[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/partition.metadata +[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/partition.metadata +[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/partition.metadata [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/partition.metadata [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/00000000000000000000.log [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/00000000000000000000.log -[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/00000000000000000000.log -[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/00000000000000000000.log +[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/00000000000000000000.log +[stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/00000000000000000000.log [stage-4] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/00000000000000000000.log [stage-4] [Serializer] Finished writing log files to: /tmp/kraft-combined-logs [stage-4] Connecting to broker at: localhost:9092 @@ -450,7 +450,7 @@ Debug = true [stage-4] 0000 | 00 00 00 60 00 01 00 10 05 c3 b0 2a 00 09 6b 61 | ...`.......*..ka [stage-4] 0010 | 66 6b 61 2d 63 6c 69 00 00 00 01 f4 00 00 00 01 | fka-cli......... [stage-4] 0020 | 03 20 00 00 00 00 00 00 00 00 00 00 00 02 00 00 | . .............. -[stage-4] 0030 | 00 00 00 00 00 00 00 00 00 00 00 00 11 09 02 00 | ................ +[stage-4] 0030 | 00 00 00 00 00 00 00 00 00 00 00 00 11 08 02 00 | ................ [stage-4] 0040 | 00 00 00 ff ff ff ff 00 00 00 00 00 00 00 00 ff | ................ [stage-4] 0050 | ff ff ff ff ff ff ff ff ff ff ff 00 10 00 00 00 | ................ [stage-4] 0060 | 00 01 01 00 | .... @@ -458,8 +458,8 @@ Debug = true [stage-4] Hexdump of received "Fetch" response:  [stage-4] Idx | Hex | ASCII [stage-4] -----+-------------------------------------------------+----------------- -[stage-4] 0000 | 05 c3 b0 2a 00 00 00 00 00 00 00 08 61 5f ef 02 | ...*........a_.. -[stage-4] 0010 | 00 00 00 00 00 00 00 00 00 00 00 00 00 00 11 09 | ................ +[stage-4] 0000 | 05 c3 b0 2a 00 00 00 00 00 00 00 02 09 4b 77 02 | ...*.........Kw. +[stage-4] 0010 | 00 00 00 00 00 00 00 00 00 00 00 00 00 00 11 08 | ................ [stage-4] 0020 | 02 00 00 00 00 00 64 ff ff ff ff ff ff ff ff ff | ......d......... [stage-4] 0030 | ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff 01 | ................ [stage-4] 0040 | ff ff ff ff 01 00 00 00 | ........ @@ -470,10 +470,10 @@ Debug = true [stage-4] [Decoder] - .ResponseBody [stage-4] [Decoder]  - .throttle_time_ms (0) [stage-4] [Decoder]  - .error_code (0) -[stage-4] [Decoder]  - .session_id (140599279) +[stage-4] [Decoder]  - .session_id (34163575) [stage-4] [Decoder]  - .num_responses (1) [stage-4] [Decoder]  - .TopicResponse[0] -[stage-4] [Decoder]  - .topic_id (00000000-0000-0000-0000-000000001109) +[stage-4] [Decoder]  - .topic_id (00000000-0000-0000-0000-000000001108) [stage-4] [Decoder]  - .num_partitions (1) [stage-4] [Decoder]  - .PartitionResponse[0] [stage-4] [Decoder]  - .partition_index (0) @@ -490,7 +490,7 @@ Debug = true [stage-4] ✓ Correlation ID: 96710698 [stage-4] ✓ Throttle Time: 0 [stage-4] ✓ Error Code: 0 (NO_ERROR) -[stage-4]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-0000-0000-000000001109 +[stage-4]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-0000-0000-000000001108 [stage-4]  ✓ PartitionResponse[0] Error code: 100 (UNKNOWN_TOPIC_ID) [stage-4]  ✓ PartitionResponse[0] Partition Index: 0 [stage-4]  ✓ RecordBatches: [] @@ -506,13 +506,13 @@ Debug = true [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/.kafka_cleanshutdown [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/partition.metadata [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/partition.metadata -[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/partition.metadata -[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/partition.metadata +[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/partition.metadata +[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/partition.metadata [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/partition.metadata [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/00000000000000000000.log [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/00000000000000000000.log -[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/00000000000000000000.log -[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/00000000000000000000.log +[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/00000000000000000000.log +[stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/00000000000000000000.log [stage-3] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/00000000000000000000.log [stage-3] [Serializer] Finished writing log files to: /tmp/kraft-combined-logs [stage-3] Connecting to broker at: localhost:9092 @@ -524,7 +524,7 @@ Debug = true [stage-3] 0000 | 00 00 00 60 00 01 00 10 0f 2e 14 fa 00 09 6b 61 | ...`..........ka [stage-3] 0010 | 66 6b 61 2d 63 6c 69 00 00 00 01 f4 00 00 00 01 | fka-cli......... [stage-3] 0020 | 03 20 00 00 00 00 00 00 00 00 00 00 00 02 00 00 | . .............. -[stage-3] 0030 | 00 00 00 00 40 00 80 00 00 00 00 00 00 31 02 00 | ....@........1.. +[stage-3] 0030 | 00 00 00 00 40 00 80 00 00 00 00 00 00 61 02 00 | ....@........a.. [stage-3] 0040 | 00 00 00 ff ff ff ff 00 00 00 00 00 00 00 00 ff | ................ [stage-3] 0050 | ff ff ff ff ff ff ff ff ff ff ff 00 10 00 00 00 | ................ [stage-3] 0060 | 00 01 01 00 | .... @@ -532,8 +532,8 @@ Debug = true [stage-3] Hexdump of received "Fetch" response:  [stage-3] Idx | Hex | ASCII [stage-3] -----+-------------------------------------------------+----------------- -[stage-3] 0000 | 0f 2e 14 fa 00 00 00 00 00 00 00 0e 3f 6d 78 02 | ............?mx. -[stage-3] 0010 | 00 00 00 00 00 00 40 00 80 00 00 00 00 00 00 31 | ......@........1 +[stage-3] 0000 | 0f 2e 14 fa 00 00 00 00 00 00 00 06 c7 4f bd 02 | .............O.. +[stage-3] 0010 | 00 00 00 00 00 00 40 00 80 00 00 00 00 00 00 61 | ......@........a [stage-3] 0020 | 02 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 | ................ [stage-3] 0030 | 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 | ................ [stage-3] 0040 | ff ff ff ff 01 00 00 00 | ........ @@ -544,10 +544,10 @@ Debug = true [stage-3] [Decoder] - .ResponseBody [stage-3] [Decoder]  - .throttle_time_ms (0) [stage-3] [Decoder]  - .error_code (0) -[stage-3] [Decoder]  - .session_id (239037816) +[stage-3] [Decoder]  - .session_id (113725373) [stage-3] [Decoder]  - .num_responses (1) [stage-3] [Decoder]  - .TopicResponse[0] -[stage-3] [Decoder]  - .topic_id (00000000-0000-4000-8000-000000000031) +[stage-3] [Decoder]  - .topic_id (00000000-0000-4000-8000-000000000061) [stage-3] [Decoder]  - .num_partitions (1) [stage-3] [Decoder]  - .PartitionResponse[0] [stage-3] [Decoder]  - .partition_index (0) @@ -564,7 +564,7 @@ Debug = true [stage-3] ✓ Correlation ID: 254678266 [stage-3] ✓ Throttle Time: 0 [stage-3] ✓ Error Code: 0 (NO_ERROR) -[stage-3]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-4000-8000-000000000031 +[stage-3]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-4000-8000-000000000061 [stage-3]  ✓ PartitionResponse[0] Error code: 0 (NO_ERROR) [stage-3]  ✓ PartitionResponse[0] Partition Index: 0 [stage-3]  ✓ RecordBatches: [] @@ -580,13 +580,13 @@ Debug = true [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/.kafka_cleanshutdown [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/partition.metadata [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/partition.metadata -[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/partition.metadata -[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/partition.metadata +[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/partition.metadata +[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/partition.metadata [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/partition.metadata [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/00000000000000000000.log [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/00000000000000000000.log -[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/00000000000000000000.log -[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/00000000000000000000.log +[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/00000000000000000000.log +[stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/00000000000000000000.log [stage-2] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/00000000000000000000.log [stage-2] [Serializer] Finished writing log files to: /tmp/kraft-combined-logs [stage-2] Connecting to broker at: localhost:9092 @@ -598,7 +598,7 @@ Debug = true [stage-2] 0000 | 00 00 00 60 00 01 00 10 70 d8 81 15 00 09 6b 61 | ...`....p.....ka [stage-2] 0010 | 66 6b 61 2d 63 6c 69 00 00 00 01 f4 00 00 00 01 | fka-cli......... [stage-2] 0020 | 03 20 00 00 00 00 00 00 00 00 00 00 00 02 00 00 | . .............. -[stage-2] 0030 | 00 00 00 00 40 00 80 00 00 00 00 00 00 32 02 00 | ....@........2.. +[stage-2] 0030 | 00 00 00 00 40 00 80 00 00 00 00 00 00 84 02 00 | ....@........... [stage-2] 0040 | 00 00 00 ff ff ff ff 00 00 00 00 00 00 00 00 ff | ................ [stage-2] 0050 | ff ff ff ff ff ff ff ff ff ff ff 00 10 00 00 00 | ................ [stage-2] 0060 | 00 01 01 00 | .... @@ -606,16 +606,17 @@ Debug = true [stage-2] Hexdump of received "Fetch" response:  [stage-2] Idx | Hex | ASCII [stage-2] -----+-------------------------------------------------+----------------- -[stage-2] 0000 | 70 d8 81 15 00 00 00 00 00 00 00 0b 66 6c 3f 02 | p...........fl?. -[stage-2] 0010 | 00 00 00 00 00 00 40 00 80 00 00 00 00 00 00 32 | ......@........2 +[stage-2] 0000 | 70 d8 81 15 00 00 00 00 00 00 00 0a f4 fb c2 02 | p............... +[stage-2] 0010 | 00 00 00 00 00 00 40 00 80 00 00 00 00 00 00 84 | ......@......... [stage-2] 0020 | 02 00 00 00 00 00 00 00 00 00 00 00 00 00 01 00 | ................ [stage-2] 0030 | 00 00 00 00 00 00 01 00 00 00 00 00 00 00 00 00 | ................ -[stage-2] 0040 | ff ff ff ff 51 00 00 00 00 00 00 00 00 00 00 00 | ....Q........... -[stage-2] 0050 | 44 00 00 00 00 02 98 ec 18 d3 00 00 00 00 00 00 | D............... +[stage-2] 0040 | ff ff ff ff 5f 00 00 00 00 00 00 00 00 00 00 00 | ...._........... +[stage-2] 0050 | 52 00 00 00 00 02 8b aa 87 2a 00 00 00 00 00 00 | R........*...... [stage-2] 0060 | 00 00 01 91 e0 5b 6d 8b 00 00 01 91 e0 5b 6d 8b | .....[m......[m. [stage-2] 0070 | 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 | ................ -[stage-2] 0080 | 00 01 24 00 00 00 01 18 48 65 6c 6c 6f 20 57 6f | ..$.....Hello Wo -[stage-2] 0090 | 72 6c 64 21 00 00 00 00 | rld!.... +[stage-2] 0080 | 00 01 40 00 00 00 01 34 48 65 6c 6c 6f 20 52 65 | ..@....4Hello Re +[stage-2] 0090 | 76 65 72 73 65 20 45 6e 67 69 6e 65 65 72 69 6e | verse Engineerin +[stage-2] 00a0 | 67 21 00 00 00 00 | g!.... [stage-2]  [stage-2] [Decoder] - .ResponseHeader [stage-2] [Decoder]  - .correlation_id (1893237013) @@ -623,10 +624,10 @@ Debug = true [stage-2] [Decoder] - .ResponseBody [stage-2] [Decoder]  - .throttle_time_ms (0) [stage-2] [Decoder]  - .error_code (0) -[stage-2] [Decoder]  - .session_id (191261759) +[stage-2] [Decoder]  - .session_id (183827394) [stage-2] [Decoder]  - .num_responses (1) [stage-2] [Decoder]  - .TopicResponse[0] -[stage-2] [Decoder]  - .topic_id (00000000-0000-4000-8000-000000000032) +[stage-2] [Decoder]  - .topic_id (00000000-0000-4000-8000-000000000084) [stage-2] [Decoder]  - .num_partitions (1) [stage-2] [Decoder]  - .PartitionResponse[0] [stage-2] [Decoder]  - .partition_index (0) @@ -636,13 +637,13 @@ Debug = true [stage-2] [Decoder]  - .log_start_offset (0) [stage-2] [Decoder]  - .num_aborted_transactions (0) [stage-2] [Decoder]  - .preferred_read_replica (-1) -[stage-2] [Decoder]  - .compact_records_length (80) +[stage-2] [Decoder]  - .compact_records_length (94) [stage-2] [Decoder]  - .RecordBatch[0] [stage-2] [Decoder]  - .base_offset (0) -[stage-2] [Decoder]  - .batch_length (68) +[stage-2] [Decoder]  - .batch_length (82) [stage-2] [Decoder]  - .partition_leader_epoch (0) [stage-2] [Decoder]  - .magic_byte (2) -[stage-2] [Decoder]  - .crc (-1729357613) +[stage-2] [Decoder]  - .crc (-1951758550) [stage-2] [Decoder]  - .record_attributes (0) [stage-2] [Decoder]  - .last_offset_delta (0) [stage-2] [Decoder]  - .base_timestamp (1726045973899) @@ -652,14 +653,14 @@ Debug = true [stage-2] [Decoder]  - .base_sequence (0) [stage-2] [Decoder]  - .num_records (1) [stage-2] [Decoder]  - .Record[0] -[stage-2] [Decoder]  - .length (18) +[stage-2] [Decoder]  - .length (32) [stage-2] [Decoder]  - .attributes (0) [stage-2] [Decoder]  - .timestamp_delta (0) [stage-2] [Decoder]  - .offset_delta (0) [stage-2] [Decoder]  - .key_length (-1) [stage-2] [Decoder]  - .key ("") -[stage-2] [Decoder]  - .value_length (12) -[stage-2] [Decoder]  - .value ("Hello World!") +[stage-2] [Decoder]  - .value_length (26) +[stage-2] [Decoder]  - .value ("Hello Reverse Engineering!") [stage-2] [Decoder]  - .num_headers (0) [stage-2] [Decoder]  - .TAG_BUFFER [stage-2] [Decoder]  - .TAG_BUFFER @@ -667,11 +668,11 @@ Debug = true [stage-2] ✓ Correlation ID: 1893237013 [stage-2] ✓ Throttle Time: 0 [stage-2] ✓ Error Code: 0 (NO_ERROR) -[stage-2]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-4000-8000-000000000032 +[stage-2]  ✓ TopicResponse[0] Topic UUID: 00000000-0000-4000-8000-000000000084 [stage-2]  ✓ PartitionResponse[0] Error code: 0 (NO_ERROR) [stage-2]  ✓ PartitionResponse[0] Partition Index: 0 [stage-2]  ✓ RecordBatch[0] BaseOffset: 0 -[stage-2]  ✓ Record[0] Value: Hello World! +[stage-2]  ✓ Record[0] Value: Hello Reverse Engineering! [stage-2] ✓ RecordBatch bytes match with the contents on disk [stage-2] Test passed. [stage-2] Terminating program @@ -685,13 +686,13 @@ Debug = true [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/.kafka_cleanshutdown [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/partition.metadata [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/partition.metadata -[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/partition.metadata -[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/partition.metadata +[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/partition.metadata +[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/partition.metadata [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/partition.metadata [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/bar-0/00000000000000000000.log [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/baz-0/00000000000000000000.log -[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-0/00000000000000000000.log -[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/quz-1/00000000000000000000.log +[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-0/00000000000000000000.log +[stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/foo-1/00000000000000000000.log [stage-1] [Serializer]  - Wrote file to: /tmp/kraft-combined-logs/__cluster_metadata-0/00000000000000000000.log [stage-1] [Serializer] Finished writing log files to: /tmp/kraft-combined-logs [stage-1] Connecting to broker at: localhost:9092 @@ -703,7 +704,7 @@ Debug = true [stage-1] 0000 | 00 00 00 60 00 01 00 10 65 3c 54 a2 00 09 6b 61 | ...`....e