2025-12-09T03:42:46.837422Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Starting read session
2025-12-09T03:42:46.837469Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:46.837911Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.837926Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.837933Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:46.842676Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Successfully connected. Initializing session
2025-12-09T03:42:46.843880Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Server session id: test_3_session_consumer_1_17_16570223808333501049_v1
2025-12-09T03:42:46.843983Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.845436Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:46.846320Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.846388Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-09T03:42:46.846423Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:42:46.846432Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-09T03:42:46.846554Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-09T03:42:46.846639Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:46.849250Z :DEBUG: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:46.849403Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:46.849440Z :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-09T03:42:46.849450Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:46.849667Z :NOTICE: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] 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:42:46.849789Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:46.849798Z :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-09T03:42:46.849813Z :INFO: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:46.849822Z :NOTICE: [local] [local] [daaddddb-8a2e4ae4-2827c015-e16f3aff] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:43.733121Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Starting read session
2025-12-09T03:43:43.733171Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:43.733603Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:43.733616Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:43.733621Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:43.738904Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] Successfully connected. Initializing session
2025-12-09T03:43:43.739949Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] Server session id: test_filters_non_optional_field_consumer_1_21_17605859348511208409_v1
2025-12-09T03:43:43.740025Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:43.741319Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [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:44.734284Z :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-09T03:43:44.734326Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:47.012245Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:47.012333Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-12-09T03:43:47.012381Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-12-09T03:43:47.012481Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] Commit offsets [10, 11). Partition stream id: 1
2025-12-09T03:43:47.012559Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:47.015327Z :DEBUG: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:47.015478Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:47.015523Z :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-09T03:43:47.015534Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3282 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:47.015779Z :NOTICE: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] 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:47.015928Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:47.015945Z :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-09T03:43:47.015965Z :INFO: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3282 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:47.015976Z :NOTICE: [local] [local] [f3f122a8-629a2ace-fef8cff1-74c27c42] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:59.091282Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Starting read session
2025-12-09T03:43:59.091323Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:59.091795Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:59.091809Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:59.091815Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:59.096735Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Successfully connected. Initializing session
2025-12-09T03:43:59.097980Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Server session id: test_stop_start_consumer_1_12_7499127496963980401_v1
2025-12-09T03:43:59.098078Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:59.099499Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 9. Read offset: (NULL)
2025-12-09T03:43:59.099640Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_stop_start_output". Partition: 7. Read offset: (NULL)
2025-12-09T03:43:59.099687Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_stop_start_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:43:59.099718Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_stop_start_output". Partition: 6. Read offset: (NULL)
2025-12-09T03:43:59.099821Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 5. Cluster: "". Topic: "test_stop_start_output". Partition: 8. Read offset: (NULL)
2025-12-09T03:43:59.099924Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 6. Cluster: "". Topic: "test_stop_start_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:43:59.100052Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 7. Cluster: "". Topic: "test_stop_start_output". Partition: 5. Read offset: (NULL)
2025-12-09T03:43:59.100163Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 8. Cluster: "". Topic: "test_stop_start_output". Partition: 4. Read offset: (NULL)
2025-12-09T03:43:59.100233Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 9. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:59.100304Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Confirm partition stream create. Partition stream id: 10. Cluster: "". Topic: "test_stop_start_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:44:00.092278Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:3:10:0:0 null:test_stop_start_output:0:9:0:0 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:5:7:0:0 null:test_stop_start_output:2:6:0:0 null:test_stop_start_output:8:5:0:0 null:test_stop_start_output:6:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:7:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-09T03:44:00.092305Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:03.715652Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:03.715784Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:44:03.715838Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:44:03.715954Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Commit offsets [0, 1). Partition stream id: 9
2025-12-09T03:44:03.716042Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:03.718666Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Committed response: cookies { assign_id: 10 partition_cookie: 1 }
2025-12-09T03:44:03.728396Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:03.728482Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 5 (0-0)
2025-12-09T03:44:03.728540Z :DEBUG: [local] Take Data. Partition 5. Read: {0, 0} (0-0)
2025-12-09T03:44:03.728634Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Commit offsets [0, 1). Partition stream id: 7
2025-12-09T03:44:03.728744Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:03.730082Z :DEBUG: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] [null] Committed response: cookies { assign_id: 5 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:03.730178Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:03.730213Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:3:10:0:0 null:test_stop_start_output:0:9:0:1 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:5:7:0:1 null:test_stop_start_output:2:6:0:0 null:test_stop_start_output:8:5:0:0 null:test_stop_start_output:6:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:7:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-09T03:44:03.730225Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4638 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:03.730433Z :NOTICE: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] 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:03.730575Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:03.730595Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:3:10:0:0 null:test_stop_start_output:0:9:0:1 null:test_stop_start_output:4:8:0:0 null:test_stop_start_output:5:7:0:1 null:test_stop_start_output:2:6:0:0 null:test_stop_start_output:8:5:0:0 null:test_stop_start_output:6:4:0:0 null:test_stop_start_output:1:3:0:0 null:test_stop_start_output:7:2:0:0 null:test_stop_start_output:9:1:0:0
2025-12-09T03:44:03.730603Z :INFO: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4639 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:03.730617Z :NOTICE: [local] [local] [2468a396-c0dc132f-3a92aef5-940fce08] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
