2025-11-11T14:18:49.503555Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Starting read session
2025-11-11T14:18:49.503598Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:49.503961Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:49.503976Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:49.503981Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:49.508969Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] Successfully connected. Initializing session
2025-11-11T14:18:49.510395Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] Server session id: test_filters_non_optional_field_consumer_1_23_1265398595476362305_v1
2025-11-11T14:18:49.510471Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:49.514194Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [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:50.504774Z :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-11-11T14:18:50.504812Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:53.904643Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:53.904747Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-11-11T14:18:53.904783Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-11-11T14:18:53.904886Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] Commit offsets [10, 11). Partition stream id: 1
2025-11-11T14:18:53.904956Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:53.907916Z :DEBUG: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:53.908075Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:53.908103Z :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-11-11T14:18:53.908114Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4404 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:53.908374Z :NOTICE: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] 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:53.910036Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:53.910050Z :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-11-11T14:18:53.910073Z :INFO: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4406 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:53.910085Z :NOTICE: [local] [local] [120b4f5f-5db120f9-3ad97a0c-60b0f1b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:17.161360Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Starting read session
2025-11-11T14:18:17.167726Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Starting session to cluster null (localhost:11255)
2025-11-11T14:18:17.168218Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:17.168231Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:17.168237Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:17.182398Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] Successfully connected. Initializing session
2025-11-11T14:18:17.183479Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] Server session id: test_filters_optional_field_consumer_1_23_15359379332224719626_v1
2025-11-11T14:18:17.183557Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:17.186316Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [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:18.169655Z :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:11
2025-11-11T14:18:18.169694Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1008 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:20.733279Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:20.734177Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-11-11T14:18:20.734208Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (11-11)
2025-11-11T14:18:20.734322Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] Commit offsets [11, 12). Partition stream id: 1
2025-11-11T14:18:20.734435Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:20.738975Z :DEBUG: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:20.739120Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:20.739170Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:11:12
2025-11-11T14:18:20.739179Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3577 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:20.739391Z :NOTICE: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] 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:20.739607Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:20.739617Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:11:12
2025-11-11T14:18:20.739636Z :INFO: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3578 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:20.739645Z :NOTICE: [local] [local] [61f8fdef-d6b2d2ad-2da9119b-38cea14f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:46.487008Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Starting read session
2025-11-11T14:16:46.487039Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:46.487386Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.487399Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.487405Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:46.492771Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Successfully connected. Initializing session
2025-11-11T14:16:46.493735Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Server session id: test_stop_start_consumer_1_14_8194064693658222152_v1
2025-11-11T14:16:46.493813Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.495140Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:47.487663Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:0:2
2025-11-11T14:16:47.487695Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.355247Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.355325Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:16:51.355371Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:51.355535Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:16:51.355756Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:51.356028Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.356085Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:16:51.356106Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:16:51.356174Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Commit offsets [3, 4). Partition stream id: 1
2025-11-11T14:16:51.356212Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:51.358540Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:51.358627Z :DEBUG: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:51.358716Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:51.358742Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:3:4
2025-11-11T14:16:51.358754Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4871 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:51.359023Z :NOTICE: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] 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:16:51.359144Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:51.359156Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:3:4
2025-11-11T14:16:51.359165Z :INFO: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4872 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.359173Z :NOTICE: [local] [local] [640fcf1e-5d2c26c-8e823df1-9691b73d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
