2025-12-12T12:36:39.186818Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Starting read session
2025-12-12T12:36:39.186854Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Starting session to cluster null (localhost:63390)
2025-12-12T12:36:39.187377Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:39.187392Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:39.187398Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:36:39.192480Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Successfully connected. Initializing session
2025-12-12T12:36:39.193554Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Server session id: test_filters_non_optional_field_consumer_1_23_3196935956757574353_v1
2025-12-12T12:36:39.193666Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:39.195100Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:36:40.188305Z :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-12T12:36:40.188350Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:42.829445Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:42.829556Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-12-12T12:36:42.829606Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (11-11)
2025-12-12T12:36:42.829714Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Commit offsets [11, 12). Partition stream id: 1
2025-12-12T12:36:42.829820Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:36:42.832268Z :DEBUG: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:36:42.832408Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Closing read session. Close timeout: 5.000000s
2025-12-12T12:36:42.832436Z :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-12T12:36:42.832447Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3645 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:36:42.832706Z :NOTICE: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] 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-12T12:36:42.832802Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Closing read session. Close timeout: 0.000000s
2025-12-12T12:36:42.832812Z :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-12T12:36:42.832831Z :INFO: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3646 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:42.832841Z :NOTICE: [local] [local] [39428262-5ebfaf71-3a88eab9-82782b2d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:51.581734Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Starting read session
2025-12-12T12:27:51.581796Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:51.582282Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:51.582296Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:51.582302Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:51.591031Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Successfully connected. Initializing session
2025-12-12T12:27:51.593031Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Server session id: test_stop_start_consumer_1_24_17476772693759160412_v1
2025-12-12T12:27:51.593150Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:51.595674Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 8. Read offset: (NULL)
2025-12-12T12:27:51.596217Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_stop_start_output". Partition: 4. Read offset: (NULL)
2025-12-12T12:27:51.596680Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_stop_start_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:27:51.596692Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:51.596806Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 5. Cluster: "". Topic: "test_stop_start_output". Partition: 5. Read offset: (NULL)
2025-12-12T12:27:51.596840Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 6. Cluster: "". Topic: "test_stop_start_output". Partition: 9. Read offset: (NULL)
2025-12-12T12:27:51.596846Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 7. Cluster: "". Topic: "test_stop_start_output". Partition: 7. Read offset: (NULL)
2025-12-12T12:27:51.596851Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 8. Cluster: "". Topic: "test_stop_start_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:27:51.596964Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 9. Cluster: "". Topic: "test_stop_start_output". Partition: 6. Read offset: (NULL)
2025-12-12T12:27:51.597017Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Confirm partition stream create. Partition stream id: 10. Cluster: "". Topic: "test_stop_start_output". Partition: 2. Read offset: (NULL)
2025-12-12T12:27:52.583309Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:2:10:0:0 null:test_stop_start_output:6:9:0:1 null:test_stop_start_output:3:8:0:0 null:test_stop_start_output:7:7:0:0 null:test_stop_start_output:9:6:0:0 null:test_stop_start_output:5:5:0:0 null:test_stop_start_output:0:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:4:2:0:0 null:test_stop_start_output:8:1:0:1
2025-12-12T12:27:52.583344Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:56.605508Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:56.605606Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 7 (0-0)
2025-12-12T12:27:56.605660Z :DEBUG: [local] Take Data. Partition 7. Read: {0, 0} (0-0)
2025-12-12T12:27:56.605779Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Commit offsets [0, 1). Partition stream id: 7
2025-12-12T12:27:56.605880Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:56.608565Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Committed response: cookies { assign_id: 3 partition_cookie: 1 }
2025-12-12T12:27:56.610028Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:56.610106Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (0-0)
2025-12-12T12:27:56.610154Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (0-0)
2025-12-12T12:27:56.610217Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Commit offsets [0, 1). Partition stream id: 8
2025-12-12T12:27:56.610298Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:56.611536Z :DEBUG: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] [null] Committed response: cookies { assign_id: 7 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:56.611655Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:56.611685Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:2:10:0:0 null:test_stop_start_output:6:9:0:1 null:test_stop_start_output:3:8:0:1 null:test_stop_start_output:7:7:0:1 null:test_stop_start_output:9:6:0:0 null:test_stop_start_output:5:5:0:0 null:test_stop_start_output:0:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:4:2:0:0 null:test_stop_start_output:8:1:0:1
2025-12-12T12:27:56.611696Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5029 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:56.615051Z :NOTICE: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] 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-12T12:27:56.618412Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:56.618431Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:2:10:0:0 null:test_stop_start_output:6:9:0:1 null:test_stop_start_output:3:8:0:1 null:test_stop_start_output:7:7:0:1 null:test_stop_start_output:9:6:0:0 null:test_stop_start_output:5:5:0:0 null:test_stop_start_output:0:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:4:2:0:0 null:test_stop_start_output:8:1:0:1
2025-12-12T12:27:56.618462Z :INFO: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5036 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:56.618489Z :NOTICE: [local] [local] [542a14f3-16daf950-2d6804b8-6fb84889] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
