2025-11-11T14:16:51.676143Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Starting read session
2025-11-11T14:16:51.676176Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:51.676531Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.676541Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.676545Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:51.681092Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Successfully connected. Initializing session
2025-11-11T14:16:51.681997Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Server session id: test_3_session_consumer_1_17_4655910083630945592_v1
2025-11-11T14:16:51.682077Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.684606Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:51.685351Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.685445Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-11-11T14:16:51.685482Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:16:51.685494Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:16:51.685566Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:16:51.685640Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:51.688197Z :DEBUG: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:51.688356Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:51.688396Z :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-11-11T14:16:51.688403Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:51.688770Z :NOTICE: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] 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.688857Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:51.688864Z :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-11-11T14:16:51.688870Z :INFO: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.688876Z :NOTICE: [local] [local] [1f0658e3-9980346d-b37a9a7c-75429faa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:41.410819Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Starting read session
2025-11-11T14:18:41.410863Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:41.411342Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:41.411360Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:41.411367Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:41.419538Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] Successfully connected. Initializing session
2025-11-11T14:18:41.420835Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] Server session id: test_filters_non_optional_field_consumer_1_21_17175692955957395056_v1
2025-11-11T14:18:41.420947Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:41.422609Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [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:42.413814Z :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:9
2025-11-11T14:18:42.433611Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:45.881855Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:45.885459Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-11-11T14:18:45.885514Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (9-9)
2025-11-11T14:18:45.889548Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] Commit offsets [9, 10). Partition stream id: 1
2025-11-11T14:18:45.889721Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:45.897395Z :DEBUG: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:45.897904Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:45.897934Z :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:9:10
2025-11-11T14:18:45.897946Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4487 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:45.899024Z :NOTICE: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] 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:45.899348Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:45.899359Z :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:9:10
2025-11-11T14:18:45.899381Z :INFO: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4488 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:45.899392Z :NOTICE: [local] [local] [dba5b0d6-5dae384-2a01db7f-8c8a4041] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:09.639321Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Starting read session
2025-11-11T14:18:09.649621Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Starting session to cluster null (localhost:11255)
2025-11-11T14:18:09.650190Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:09.650204Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:09.650212Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:09.659382Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] Successfully connected. Initializing session
2025-11-11T14:18:09.663878Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] Server session id: test_filters_optional_field_consumer_1_21_11083830881218821541_v1
2025-11-11T14:18:09.670027Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:09.671539Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [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:10.653728Z :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:10
2025-11-11T14:18:10.653769Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1014 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:12.789735Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:12.797467Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-11-11T14:18:12.797530Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-11-11T14:18:12.798522Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] Commit offsets [10, 11). Partition stream id: 1
2025-11-11T14:18:12.798964Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:12.807502Z :DEBUG: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:12.845766Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:12.845813Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:10:11
2025-11-11T14:18:12.845827Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3206 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:12.848751Z :NOTICE: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] 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:12.857500Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:12.857526Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:10:11
2025-11-11T14:18:12.857550Z :INFO: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3218 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:12.857569Z :NOTICE: [local] [local] [950adde7-555a1d43-ec526a11-b8b3aae8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:39.478947Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Starting read session
2025-11-11T14:16:39.478986Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:39.479371Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:39.479383Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:39.479390Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:39.484527Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Successfully connected. Initializing session
2025-11-11T14:16:39.485616Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Server session id: test_stop_start_consumer_1_12_8058856689606887656_v1
2025-11-11T14:16:39.485676Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:39.487812Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:40.479675Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:0:0
2025-11-11T14:16:40.479709Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:43.225080Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:43.225151Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:43.225194Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:43.225298Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:43.225434Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:43.225586Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:43.225623Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:43.225638Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:43.225678Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:43.225755Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:43.227688Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:43.227764Z :DEBUG: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:43.227843Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:43.227892Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:1:2
2025-11-11T14:16:43.227900Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3748 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:43.228089Z :NOTICE: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] 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:43.228241Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:43.228248Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:1:2
2025-11-11T14:16:43.228255Z :INFO: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3749 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:43.228265Z :NOTICE: [local] [local] [4800815b-2382e0fc-ffd3407c-54e41bcf] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
