2025-12-09T03:43:50.872402Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Starting read session
2025-12-09T03:43:50.872443Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:50.872898Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.872912Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.872919Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:50.878132Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Successfully connected. Initializing session
2025-12-09T03:43:50.879438Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Server session id: test_filters_non_optional_field_consumer_1_23_17769454838849015481_v1
2025-12-09T03:43:50.879490Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.880860Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:51.873213Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:0:11
2025-12-09T03:43:51.873246Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:54.620524Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:54.620601Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-12-09T03:43:54.620645Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (11-11)
2025-12-09T03:43:54.620760Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Commit offsets [11, 12). Partition stream id: 1
2025-12-09T03:43:54.620861Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:54.623274Z :DEBUG: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:54.623382Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:54.623402Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:11:12
2025-12-09T03:43:54.623409Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3751 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:54.623649Z :NOTICE: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-09T03:43:54.627026Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:54.627042Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:11:12
2025-12-09T03:43:54.627059Z :INFO: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3754 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:54.627081Z :NOTICE: [local] [local] [feba57df-255035a2-2b2215d1-6336ca42] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:08.555103Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Starting read session
2025-12-09T03:44:08.555140Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Starting session to cluster null (localhost:25706)
2025-12-09T03:44:08.555568Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:08.555584Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:08.555590Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:08.560992Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Successfully connected. Initializing session
2025-12-09T03:44:08.562214Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Server session id: test_stop_start_consumer_1_23_8538368063055398125_v1
2025-12-09T03:44:08.562314Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:08.563666Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 6. Read offset: (NULL)
2025-12-09T03:44:08.563748Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_stop_start_output". Partition: 9. Read offset: (NULL)
2025-12-09T03:44:08.563760Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_stop_start_output". Partition: 5. Read offset: (NULL)
2025-12-09T03:44:08.563766Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_stop_start_output". Partition: 8. Read offset: (NULL)
2025-12-09T03:44:08.563897Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 5. Cluster: "". Topic: "test_stop_start_output". Partition: 7. Read offset: (NULL)
2025-12-09T03:44:08.564076Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 6. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:08.564135Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 7. Cluster: "". Topic: "test_stop_start_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:44:08.564178Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 8. Cluster: "". Topic: "test_stop_start_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:44:08.564400Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 9. Cluster: "". Topic: "test_stop_start_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:44:08.564484Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Confirm partition stream create. Partition stream id: 10. Cluster: "". Topic: "test_stop_start_output". Partition: 4. Read offset: (NULL)
2025-12-09T03:44:09.556353Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:4:10:0:0 null:test_stop_start_output:1:9:0:0 null:test_stop_start_output:3:8:0:0 null:test_stop_start_output:2:7:0:0 null:test_stop_start_output:0:6:0:1 null:test_stop_start_output:7:5:0:0 null:test_stop_start_output:8:4:0:0 null:test_stop_start_output:5:3:0:1 null:test_stop_start_output:9:2:0:0 null:test_stop_start_output:6:1:0:0
2025-12-09T03:44:09.556388Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:13.508815Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:13.508912Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 5 (1-1)
2025-12-09T03:44:13.508967Z :DEBUG: [local] Take Data. Partition 5. Read: {0, 0} (1-1)
2025-12-09T03:44:13.509088Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Commit offsets [1, 2). Partition stream id: 3
2025-12-09T03:44:13.509234Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:13.509363Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:13.509423Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-09T03:44:13.509477Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-09T03:44:13.509531Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Commit offsets [1, 2). Partition stream id: 6
2025-12-09T03:44:13.509624Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:13.511488Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Committed response: cookies { assign_id: 5 partition_cookie: 1 }
2025-12-09T03:44:13.511554Z :DEBUG: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] [null] Committed response: cookies { assign_id: 10 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:13.511629Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:13.511654Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:4:10:0:0 null:test_stop_start_output:1:9:0:0 null:test_stop_start_output:3:8:0:0 null:test_stop_start_output:2:7:0:0 null:test_stop_start_output:0:6:1:2 null:test_stop_start_output:7:5:0:0 null:test_stop_start_output:8:4:0:0 null:test_stop_start_output:5:3:1:2 null:test_stop_start_output:9:2:0:0 null:test_stop_start_output:6:1:0:0
2025-12-09T03:44:13.511663Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4956 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:13.511882Z :NOTICE: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-09T03:44:13.511979Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:13.511990Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:4:10:0:0 null:test_stop_start_output:1:9:0:0 null:test_stop_start_output:3:8:0:0 null:test_stop_start_output:2:7:0:0 null:test_stop_start_output:0:6:1:2 null:test_stop_start_output:7:5:0:0 null:test_stop_start_output:8:4:0:0 null:test_stop_start_output:5:3:1:2 null:test_stop_start_output:9:2:0:0 null:test_stop_start_output:6:1:0:0
2025-12-09T03:44:13.512004Z :INFO: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4956 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:13.512018Z :NOTICE: [local] [local] [ddbe754d-1afc6d27-3b3afd51-5796c4a2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
