2025-12-12T12:28:28.327328Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Starting read session
2025-12-12T12:28:28.327373Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:28.327863Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.327876Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.327882Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:28.347366Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Successfully connected. Initializing session
2025-12-12T12:28:28.348986Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Server session id: test_3_session_consumer_1_17_10577752600947264008_v1
2025-12-12T12:28:28.349117Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.350567Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:28.351444Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.351552Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-12T12:28:28.351588Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:28:28.351597Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T12:28:28.351693Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T12:28:28.351791Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:28.354975Z :DEBUG: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:28.355132Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:28.355175Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:5:6
2025-12-12T12:28:28.355185Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Counters: { Errors: 0 CurrentSessionLifetimeMs: 27 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:28.355365Z :NOTICE: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] 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:28:28.355488Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:28.355496Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:5:6
2025-12-12T12:28:28.355504Z :INFO: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Counters: { Errors: 0 CurrentSessionLifetimeMs: 28 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:28.355522Z :NOTICE: [local] [local] [b1036a86-793b8de6-4f0e30b6-cd3beab] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:36:32.431568Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Starting read session
2025-12-12T12:36:32.431617Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Starting session to cluster null (localhost:63390)
2025-12-12T12:36:32.432219Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:32.432507Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:32.432518Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:36:32.438581Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] Successfully connected. Initializing session
2025-12-12T12:36:32.442929Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] Server session id: test_filters_non_optional_field_consumer_1_21_1643270928933668474_v1
2025-12-12T12:36:32.443589Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:32.447347Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [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:33.432323Z :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:10
2025-12-12T12:36:33.432365Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:36.230770Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:36.230865Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-12-12T12:36:36.230914Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-12-12T12:36:36.231057Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] Commit offsets [10, 11). Partition stream id: 1
2025-12-12T12:36:36.231157Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:36:36.233904Z :DEBUG: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:36:36.234065Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Closing read session. Close timeout: 5.000000s
2025-12-12T12:36:36.234095Z :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:10:11
2025-12-12T12:36:36.234106Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3802 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:36:36.234401Z :NOTICE: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] 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:36.234548Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Closing read session. Close timeout: 0.000000s
2025-12-12T12:36:36.234564Z :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:10:11
2025-12-12T12:36:36.234586Z :INFO: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3803 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:36.234596Z :NOTICE: [local] [local] [e6cc7a2d-8d199d5a-9fde2842-e1f21d51] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:42.867921Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Starting read session
2025-12-12T12:27:42.867968Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:42.868397Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:42.868410Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:42.868416Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:42.873825Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Successfully connected. Initializing session
2025-12-12T12:27:42.874972Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Server session id: test_stop_start_consumer_1_13_6090488969039296454_v1
2025-12-12T12:27:42.875098Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:42.876896Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 9. Read offset: (NULL)
2025-12-12T12:27:42.878531Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_stop_start_output". Partition: 2. Read offset: (NULL)
2025-12-12T12:27:42.878594Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_stop_start_output". Partition: 5. Read offset: (NULL)
2025-12-12T12:27:42.878606Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_stop_start_output". Partition: 8. Read offset: (NULL)
2025-12-12T12:27:42.878831Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 5. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:42.878903Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 6. Cluster: "". Topic: "test_stop_start_output". Partition: 7. Read offset: (NULL)
2025-12-12T12:27:42.878949Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 7. Cluster: "". Topic: "test_stop_start_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:27:42.878987Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 8. Cluster: "". Topic: "test_stop_start_output". Partition: 4. Read offset: (NULL)
2025-12-12T12:27:42.879058Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 9. Cluster: "". Topic: "test_stop_start_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:27:42.879111Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Confirm partition stream create. Partition stream id: 10. Cluster: "". Topic: "test_stop_start_output". Partition: 6. Read offset: (NULL)
2025-12-12T12:27:43.869272Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:6:10:0:0 null:test_stop_start_output:3:9:0:0 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:1:7:0:0 null:test_stop_start_output:7:6:0:0 null:test_stop_start_output:8:4:0:0 null:test_stop_start_output:0:5:0:0 null:test_stop_start_output:5:3:0:0 null:test_stop_start_output:2:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-12T12:27:43.869308Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:47.076210Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:47.077203Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 6 (0-0)
2025-12-12T12:27:47.077267Z :DEBUG: [local] Take Data. Partition 6. Read: {0, 0} (0-0)
2025-12-12T12:27:47.077431Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Commit offsets [0, 1). Partition stream id: 10
2025-12-12T12:27:47.077562Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:47.079329Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:47.082162Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-12-12T12:27:47.083066Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 8 (0-0)
2025-12-12T12:27:47.083128Z :DEBUG: [local] Take Data. Partition 8. Read: {0, 0} (0-0)
2025-12-12T12:27:47.083182Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Commit offsets [0, 1). Partition stream id: 4
2025-12-12T12:27:47.083330Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:47.085082Z :DEBUG: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:47.087089Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:47.087127Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:6:10:0:1 null:test_stop_start_output:3:9:0:0 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:1:7:0:0 null:test_stop_start_output:7:6:0:0 null:test_stop_start_output:8:4:0:1 null:test_stop_start_output:0:5:0:0 null:test_stop_start_output:5:3:0:0 null:test_stop_start_output:2:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-12T12:27:47.087140Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4219 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:47.087373Z :NOTICE: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] 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:47.091170Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:47.091191Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:6:10:0:1 null:test_stop_start_output:3:9:0:0 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:1:7:0:0 null:test_stop_start_output:7:6:0:0 null:test_stop_start_output:8:4:0:1 null:test_stop_start_output:0:5:0:0 null:test_stop_start_output:5:3:0:0 null:test_stop_start_output:2:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-12T12:27:47.091203Z :INFO: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4223 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:47.091231Z :NOTICE: [local] [local] [954278f-b7ddcf4e-ba5e9cec-b3637e9a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
