2025-11-11T14:18:56.567248Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Starting read session
2025-11-11T14:18:56.570508Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:56.571150Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:56.571167Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:56.571175Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:56.585673Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Successfully connected. Initializing session
2025-11-11T14:18:56.617763Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Server session id: test_filters_non_optional_field_consumer_1_25_11360819974621028687_v1
2025-11-11T14:18:56.621117Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:56.621402Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:57.571735Z :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-11-11T14:18:57.573523Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1004 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:00.837549Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:00.838661Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-11-11T14:19:00.838686Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (11-11)
2025-11-11T14:19:00.838765Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Commit offsets [11, 12). Partition stream id: 1
2025-11-11T14:19:00.838834Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:19:00.841456Z :DEBUG: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:19:00.842462Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Closing read session. Close timeout: 5.000000s
2025-11-11T14:19:00.842492Z :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-11-11T14:19:00.842505Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4275 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:19:00.842727Z :NOTICE: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] 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-11-11T14:19:00.843378Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Closing read session. Close timeout: 0.000000s
2025-11-11T14:19:00.843393Z :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-11-11T14:19:00.843413Z :INFO: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4276 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:00.843423Z :NOTICE: [local] [local] [6e407984-4482bae1-d1427fc9-88649412] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:25.430450Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Starting read session
2025-11-11T14:18:25.430492Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Starting session to cluster null (localhost:11255)
2025-11-11T14:18:25.430923Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.437779Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.437798Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:25.443541Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Successfully connected. Initializing session
2025-11-11T14:18:25.456441Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Server session id: test_filters_optional_field_consumer_1_25_10356567798900827876_v1
2025-11-11T14:18:25.457273Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.459847Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:26.433519Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:0:12
2025-11-11T14:18:26.433562Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:28.683081Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:28.684095Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (12-12)
2025-11-11T14:18:28.684413Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (12-12)
2025-11-11T14:18:28.684517Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Commit offsets [12, 13). Partition stream id: 1
2025-11-11T14:18:28.684644Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:28.687879Z :DEBUG: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:28.689986Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:28.690014Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:12:13
2025-11-11T14:18:28.690023Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3259 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:28.693490Z :NOTICE: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] 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-11-11T14:18:28.693644Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:28.693657Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:12:13
2025-11-11T14:18:28.693697Z :INFO: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3263 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:28.693708Z :NOTICE: [local] [local] [a3ce450e-b385148a-3fa0d25d-dcc16acc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
