2025-12-12T11:57:08.681244Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [] Write session: try to update token
2025-12-12T11:57:08.681393Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [] Write session: Do CDS request
2025-12-12T11:57:08.682735Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [] Start write session. Will connect to endpoint: localhost:6718
2025-12-12T11:57:08.695102Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [] Write session: send init request: init_request { topic: "sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic" message_group_id: "test-message_group_id" }
2025-12-12T11:57:08.702426Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540628702 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:08.702497Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [] Write session established. Init response: session_id: "test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0" topic: "sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic"
2025-12-12T11:57:08.705341Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:08.707989Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.708014Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:08.720318Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 2 to 2
2025-12-12T11:57:08.722533Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.722558Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T11:57:08.726927Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 1 offsets: 0 already_written: false write_statistics { persist_duration_ms: 8 }
2025-12-12T11:57:08.726953Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 1
2025-12-12T11:57:08.733348Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 3 to 3
2025-12-12T11:57:08.735881Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.735910Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T11:57:08.737880Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 2 offsets: 1 already_written: false write_statistics { persist_duration_ms: 5 }
2025-12-12T11:57:08.737902Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 2
2025-12-12T11:57:08.745345Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 4 to 4
2025-12-12T11:57:08.747821Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.747840Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T11:57:08.758080Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 5 to 5
2025-12-12T11:57:08.759736Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.759757Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 5
2025-12-12T11:57:08.761668Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 3 offsets: 2 already_written: false write_statistics { persist_duration_ms: 14 }
2025-12-12T11:57:08.761688Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 3
2025-12-12T11:57:08.762421Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 4 offsets: 3 already_written: false write_statistics { persist_duration_ms: 5 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:08.762434Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 4
2025-12-12T11:57:08.767461Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 6 to 6
2025-12-12T11:57:08.767816Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.767831Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 6
2025-12-12T11:57:08.778109Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 7 to 7
2025-12-12T11:57:08.780525Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.780551Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 7
2025-12-12T11:57:08.790740Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 8 to 8
2025-12-12T11:57:08.793243Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.793266Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 8
2025-12-12T11:57:08.797052Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 5 offsets: 4 already_written: false write_statistics { persist_duration_ms: 10 }
2025-12-12T11:57:08.797087Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 5
2025-12-12T11:57:08.797246Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 6 offsets: 5 already_written: false write_statistics { persist_duration_ms: 8 queued_in_partition_duration_ms: 6 }
2025-12-12T11:57:08.797253Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 6
2025-12-12T11:57:08.797277Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 7 offsets: 6 already_written: false write_statistics { persist_duration_ms: 7 queued_in_partition_duration_ms: 4 }
2025-12-12T11:57:08.797279Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 7
2025-12-12T11:57:08.801204Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 8 offsets: 7 already_written: false write_statistics { persist_duration_ms: 5 }
2025-12-12T11:57:08.801224Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 8
2025-12-12T11:57:08.802671Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 9 to 9
2025-12-12T11:57:08.803006Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.803022Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 9
2025-12-12T11:57:08.810176Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 10 to 10
2025-12-12T11:57:08.810470Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.810484Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 10
2025-12-12T11:57:08.822123Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 11 to 11
2025-12-12T11:57:08.824555Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.824579Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 11
2025-12-12T11:57:08.830901Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 9 offsets: 8 already_written: false write_statistics { persist_duration_ms: 14 }
2025-12-12T11:57:08.830927Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 9
2025-12-12T11:57:08.833725Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 12 to 12
2025-12-12T11:57:08.836296Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.836323Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 12
2025-12-12T11:57:08.838041Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 10 offsets: 9 already_written: false write_statistics { persist_duration_ms: 8 queued_in_partition_duration_ms: 8 }
2025-12-12T11:57:08.838063Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 10
2025-12-12T11:57:08.838131Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 11 offsets: 10 already_written: false write_statistics { persist_duration_ms: 8 queued_in_partition_duration_ms: 1 }
2025-12-12T11:57:08.838134Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 11
2025-12-12T11:57:08.844326Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 12 offsets: 11 already_written: false write_statistics { persist_duration_ms: 5 }
2025-12-12T11:57:08.844351Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 12
2025-12-12T11:57:08.846909Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 13 to 13
2025-12-12T11:57:08.847272Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.847285Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 13
2025-12-12T11:57:08.854577Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 14 to 14
2025-12-12T11:57:08.856962Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.856986Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 14
2025-12-12T11:57:08.866120Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 15 to 15
2025-12-12T11:57:08.868341Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.868359Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 15
2025-12-12T11:57:08.871865Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 13 offsets: 12 already_written: false write_statistics { persist_duration_ms: 9 }
2025-12-12T11:57:08.871890Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 13
2025-12-12T11:57:08.875565Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 16 to 16
2025-12-12T11:57:08.877949Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.877969Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 16
2025-12-12T11:57:08.881272Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 14 offsets: 13 already_written: false write_statistics { persist_duration_ms: 9 queued_in_partition_duration_ms: 6 }
2025-12-12T11:57:08.881299Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 14
2025-12-12T11:57:08.881487Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 15 offsets: 14 already_written: false write_statistics { persist_duration_ms: 4 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:08.881493Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 15
2025-12-12T11:57:08.884926Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 17 to 17
2025-12-12T11:57:08.885257Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.885268Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 17
2025-12-12T11:57:08.886710Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 16 offsets: 15 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:08.886725Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 16
2025-12-12T11:57:08.893645Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 18 to 18
2025-12-12T11:57:08.896088Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.896110Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 18
2025-12-12T11:57:08.908478Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 19 to 19
2025-12-12T11:57:08.911044Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.911070Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 19
2025-12-12T11:57:08.913391Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 17 offsets: 16 already_written: false write_statistics { persist_duration_ms: 11 }
2025-12-12T11:57:08.913435Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 17
2025-12-12T11:57:08.916262Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 18 offsets: 17 already_written: false write_statistics { persist_duration_ms: 4 queued_in_partition_duration_ms: 9 }
2025-12-12T11:57:08.916282Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 18
2025-12-12T11:57:08.918931Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 20 to 20
2025-12-12T11:57:08.919241Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.919253Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 20
2025-12-12T11:57:08.920814Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 19 offsets: 18 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:08.920830Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 19
2025-12-12T11:57:08.926218Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 20 offsets: 19 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:08.926242Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 20
2025-12-12T11:57:08.926956Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 21 to 21
2025-12-12T11:57:08.927302Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.927317Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 21
2025-12-12T11:57:08.937791Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 22 to 22
2025-12-12T11:57:08.940248Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.940275Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 22
2025-12-12T11:57:08.953624Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 23 to 23
2025-12-12T11:57:08.956311Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.956345Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 23
2025-12-12T11:57:08.958084Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 21 offsets: 20 already_written: false write_statistics { persist_duration_ms: 17 }
2025-12-12T11:57:08.958108Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 21
2025-12-12T11:57:08.961441Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 22 offsets: 21 already_written: false write_statistics { persist_duration_ms: 5 queued_in_partition_duration_ms: 10 }
2025-12-12T11:57:08.961476Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 22
2025-12-12T11:57:08.964563Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 23 offsets: 22 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:08.964589Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 23
2025-12-12T11:57:08.967322Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 24 to 24
2025-12-12T11:57:08.967676Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.967692Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 24
2025-12-12T11:57:08.975998Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 25 to 25
2025-12-12T11:57:08.978678Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.978704Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 25
2025-12-12T11:57:08.980621Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 24 offsets: 23 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:08.980643Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 24
2025-12-12T11:57:08.988885Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 26 to 26
2025-12-12T11:57:08.991547Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:08.991572Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 26
2025-12-12T11:57:09.000993Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 25 offsets: 24 already_written: false write_statistics { persist_duration_ms: 11 }
2025-12-12T11:57:09.001021Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 25
2025-12-12T11:57:09.001482Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 27 to 27
2025-12-12T11:57:09.004075Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.004096Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 27
2025-12-12T11:57:09.006611Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 26 offsets: 25 already_written: false write_statistics { persist_duration_ms: 8 }
2025-12-12T11:57:09.006638Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 26
2025-12-12T11:57:09.011598Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 28 to 28
2025-12-12T11:57:09.013900Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.013919Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 28
2025-12-12T11:57:09.015942Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 27 offsets: 26 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.015962Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 27
2025-12-12T11:57:09.020879Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 29 to 29
2025-12-12T11:57:09.023241Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.023260Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 29
2025-12-12T11:57:09.029093Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 28 offsets: 27 already_written: false write_statistics { persist_duration_ms: 10 }
2025-12-12T11:57:09.029116Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 28
2025-12-12T11:57:09.031497Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 30 to 30
2025-12-12T11:57:09.033956Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.033984Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 30
2025-12-12T11:57:09.043073Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 31 to 31
2025-12-12T11:57:09.045467Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.045486Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 31
2025-12-12T11:57:09.047690Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 29 offsets: 28 already_written: false write_statistics { persist_duration_ms: 14 queued_in_partition_duration_ms: 1 }
2025-12-12T11:57:09.047714Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 29
2025-12-12T11:57:09.052535Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 32 to 32
2025-12-12T11:57:09.055067Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.055095Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 32
2025-12-12T11:57:09.066931Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 33 to 33
2025-12-12T11:57:09.069794Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.069825Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 33
2025-12-12T11:57:09.076144Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 30 offsets: 29 already_written: false write_statistics { persist_duration_ms: 15 queued_in_partition_duration_ms: 1 }
2025-12-12T11:57:09.076208Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 30
2025-12-12T11:57:09.076505Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 31 offsets: 30 already_written: false write_statistics { persist_duration_ms: 11 queued_in_partition_duration_ms: 6 }
2025-12-12T11:57:09.076515Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 31
2025-12-12T11:57:09.076603Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 32 offsets: 31 already_written: false write_statistics { persist_duration_ms: 5 queued_in_partition_duration_ms: 4 }
2025-12-12T11:57:09.076608Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 32
2025-12-12T11:57:09.079427Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 34 to 34
2025-12-12T11:57:09.079798Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.079816Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 34
2025-12-12T11:57:09.088897Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 35 to 35
2025-12-12T11:57:09.091710Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.091734Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 35
2025-12-12T11:57:09.096315Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 33 offsets: 32 already_written: false write_statistics { persist_duration_ms: 15 }
2025-12-12T11:57:09.096335Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 33
2025-12-12T11:57:09.101062Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 36 to 36
2025-12-12T11:57:09.103830Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.103851Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 36
2025-12-12T11:57:09.105935Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 34 offsets: 33 already_written: false write_statistics { persist_duration_ms: 15 }
2025-12-12T11:57:09.105955Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 34
2025-12-12T11:57:09.109409Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 35 offsets: 34 already_written: false write_statistics { persist_duration_ms: 4 queued_in_partition_duration_ms: 8 }
2025-12-12T11:57:09.109430Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 35
2025-12-12T11:57:09.111931Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 36 offsets: 35 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.111949Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 36
2025-12-12T11:57:09.115047Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 37 to 37
2025-12-12T11:57:09.117535Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.117554Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 37
2025-12-12T11:57:09.125046Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 38 to 38
2025-12-12T11:57:09.127268Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.127284Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 38
2025-12-12T11:57:09.129595Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 37 offsets: 36 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.129613Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 37
2025-12-12T11:57:09.134325Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 39 to 39
2025-12-12T11:57:09.136683Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.136699Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 39
2025-12-12T11:57:09.138629Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 38 offsets: 37 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.138658Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 38
2025-12-12T11:57:09.145285Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 40 to 40
2025-12-12T11:57:09.147479Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.147494Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 40
2025-12-12T11:57:09.148909Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 39 offsets: 38 already_written: false write_statistics { persist_duration_ms: 6 }
2025-12-12T11:57:09.148926Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 39
2025-12-12T11:57:09.155177Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 41 to 41
2025-12-12T11:57:09.157743Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.157765Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 41
2025-12-12T11:57:09.159287Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 40 offsets: 39 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.159305Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 40
2025-12-12T11:57:09.164952Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 42 to 42
2025-12-12T11:57:09.167270Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.167286Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 42
2025-12-12T11:57:09.173091Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 41 offsets: 40 already_written: false write_statistics { persist_duration_ms: 7 }
2025-12-12T11:57:09.173117Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 41
2025-12-12T11:57:09.174349Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 43 to 43
2025-12-12T11:57:09.176676Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.176694Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 43
2025-12-12T11:57:09.178259Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 42 offsets: 41 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.178274Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 42
2025-12-12T11:57:09.183224Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 43 offsets: 42 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.183242Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 43
2025-12-12T11:57:09.184034Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 44 to 44
2025-12-12T11:57:09.186289Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.186307Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 44
2025-12-12T11:57:09.192510Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 44 offsets: 43 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.192532Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 44
2025-12-12T11:57:09.193606Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 45 to 45
2025-12-12T11:57:09.196019Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.196035Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 45
2025-12-12T11:57:09.202724Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 46 to 46
2025-12-12T11:57:09.205266Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.205291Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 46
2025-12-12T11:57:09.206972Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 45 offsets: 44 already_written: false write_statistics { persist_duration_ms: 8 }
2025-12-12T11:57:09.206992Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 45
2025-12-12T11:57:09.211993Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 46 offsets: 45 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.212015Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 46
2025-12-12T11:57:09.213582Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 47 to 47
2025-12-12T11:57:09.215572Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.215591Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 47
2025-12-12T11:57:09.222682Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 47 offsets: 46 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 1 }
2025-12-12T11:57:09.222706Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 47
2025-12-12T11:57:09.224238Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 48 to 48
2025-12-12T11:57:09.225936Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.225954Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 48
2025-12-12T11:57:09.232779Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 48 offsets: 47 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.232801Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 48
2025-12-12T11:57:09.234222Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 49 to 49
2025-12-12T11:57:09.236821Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.236851Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 49
2025-12-12T11:57:09.247251Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 50 to 50
2025-12-12T11:57:09.249988Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.250019Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 50
2025-12-12T11:57:09.251393Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 49 offsets: 48 already_written: false write_statistics { persist_duration_ms: 9 }
2025-12-12T11:57:09.251416Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 49
2025-12-12T11:57:09.258962Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 51 to 51
2025-12-12T11:57:09.261329Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.261350Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 51
2025-12-12T11:57:09.263678Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 50 offsets: 49 already_written: false write_statistics { persist_duration_ms: 8 }
2025-12-12T11:57:09.263698Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 50
2025-12-12T11:57:09.269787Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 51 offsets: 50 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.269809Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 51
2025-12-12T11:57:09.270566Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 52 to 52
2025-12-12T11:57:09.273003Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.273020Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 52
2025-12-12T11:57:09.279822Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 52 offsets: 51 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 1 }
2025-12-12T11:57:09.279864Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 52
2025-12-12T11:57:09.284035Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 53 to 53
2025-12-12T11:57:09.286623Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.286645Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 53
2025-12-12T11:57:09.299073Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 54 to 54
2025-12-12T11:57:09.301617Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.301638Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 54
2025-12-12T11:57:09.305772Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 53 offsets: 52 already_written: false write_statistics { persist_duration_ms: 12 }
2025-12-12T11:57:09.305794Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 53
2025-12-12T11:57:09.308338Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 54 offsets: 53 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.308359Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 54
2025-12-12T11:57:09.311043Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 55 to 55
2025-12-12T11:57:09.313600Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.313625Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 55
2025-12-12T11:57:09.320622Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 55 offsets: 54 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.320650Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 55
2025-12-12T11:57:09.323845Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 56 to 56
2025-12-12T11:57:09.325738Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.325759Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 56
2025-12-12T11:57:09.332602Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 56 offsets: 55 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.332631Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 56
2025-12-12T11:57:09.335604Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 57 to 57
2025-12-12T11:57:09.338054Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.338084Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 57
2025-12-12T11:57:09.348156Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 58 to 58
2025-12-12T11:57:09.350589Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.350619Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 58
2025-12-12T11:57:09.358233Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 59 to 59
2025-12-12T11:57:09.360587Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.360604Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 59
2025-12-12T11:57:09.368360Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 60 to 60
2025-12-12T11:57:09.370935Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.370959Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 60
2025-12-12T11:57:09.384072Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 61 to 61
2025-12-12T11:57:09.386620Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.386647Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 61
2025-12-12T11:57:09.392902Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 57 offsets: 56 already_written: false write_statistics { persist_duration_ms: 50 }
2025-12-12T11:57:09.392927Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 57
2025-12-12T11:57:09.397866Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 62 to 62
2025-12-12T11:57:09.400573Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.400599Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 62
2025-12-12T11:57:09.404398Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 58 offsets: 57 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.404424Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 58
2025-12-12T11:57:09.404596Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 59 offsets: 58 already_written: false write_statistics { persist_duration_ms: 6 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.404606Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 59
2025-12-12T11:57:09.404635Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 60 offsets: 59 already_written: false write_statistics { persist_duration_ms: 5 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.404638Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 60
2025-12-12T11:57:09.410394Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 63 to 63
2025-12-12T11:57:09.412833Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.412856Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 63
2025-12-12T11:57:09.419365Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 61 offsets: 60 already_written: false write_statistics { persist_duration_ms: 16 queued_in_partition_duration_ms: 3 }
2025-12-12T11:57:09.419408Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 61
2025-12-12T11:57:09.423638Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 64 to 64
2025-12-12T11:57:09.426015Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.426039Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 64
2025-12-12T11:57:09.429274Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 62 offsets: 61 already_written: false write_statistics { persist_duration_ms: 10 }
2025-12-12T11:57:09.429325Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 62
2025-12-12T11:57:09.432909Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 63 offsets: 62 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 8 }
2025-12-12T11:57:09.432932Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 63
2025-12-12T11:57:09.434383Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 65 to 65
2025-12-12T11:57:09.436902Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.436927Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 65
2025-12-12T11:57:09.439570Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 64 offsets: 63 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.439601Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 64
2025-12-12T11:57:09.447453Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 66 to 66
2025-12-12T11:57:09.450319Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.450351Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 66
2025-12-12T11:57:09.459517Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 65 offsets: 64 already_written: false write_statistics { persist_duration_ms: 13 }
2025-12-12T11:57:09.459544Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 65
2025-12-12T11:57:09.460600Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 67 to 67
2025-12-12T11:57:09.463321Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.463350Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 67
2025-12-12T11:57:09.465665Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 66 offsets: 65 already_written: false write_statistics { persist_duration_ms: 4 queued_in_partition_duration_ms: 5 }
2025-12-12T11:57:09.465693Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 66
2025-12-12T11:57:09.470547Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 67 offsets: 66 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.470576Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 67
2025-12-12T11:57:09.474230Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 68 to 68
2025-12-12T11:57:09.476456Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.476473Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 68
2025-12-12T11:57:09.482927Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 69 to 69
2025-12-12T11:57:09.485339Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.485360Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 69
2025-12-12T11:57:09.488245Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 68 offsets: 67 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.488265Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 68
2025-12-12T11:57:09.495460Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 70 to 70
2025-12-12T11:57:09.497958Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.497985Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 70
2025-12-12T11:57:09.500415Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 69 offsets: 68 already_written: false write_statistics { persist_duration_ms: 8 }
2025-12-12T11:57:09.500436Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 69
2025-12-12T11:57:09.505213Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 70 offsets: 69 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.505240Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 70
2025-12-12T11:57:09.508321Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 71 to 71
2025-12-12T11:57:09.510904Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.510934Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 71
2025-12-12T11:57:09.518243Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 71 offsets: 70 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.518269Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 71
2025-12-12T11:57:09.519680Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 72 to 72
2025-12-12T11:57:09.522144Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.522168Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 72
2025-12-12T11:57:09.529492Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 72 offsets: 71 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.529518Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 72
2025-12-12T11:57:09.529990Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 73 to 73
2025-12-12T11:57:09.532341Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.532364Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 73
2025-12-12T11:57:09.540751Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 74 to 74
2025-12-12T11:57:09.543288Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.543319Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 74
2025-12-12T11:57:09.544994Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 73 offsets: 72 already_written: false write_statistics { persist_duration_ms: 7 }
2025-12-12T11:57:09.545016Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 73
2025-12-12T11:57:09.550534Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 74 offsets: 73 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.550558Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 74
2025-12-12T11:57:09.553458Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 75 to 75
2025-12-12T11:57:09.555934Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.555964Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 75
2025-12-12T11:57:09.563548Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 75 offsets: 74 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.563574Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 75
2025-12-12T11:57:09.564328Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 76 to 76
2025-12-12T11:57:09.566890Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.566913Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 76
2025-12-12T11:57:09.574047Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 77 to 77
2025-12-12T11:57:09.577001Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.577027Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 77
2025-12-12T11:57:09.578829Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 76 offsets: 75 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.578857Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 76
2025-12-12T11:57:09.586687Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 78 to 78
2025-12-12T11:57:09.589319Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.589347Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 78
2025-12-12T11:57:09.591175Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 77 offsets: 76 already_written: false write_statistics { persist_duration_ms: 10 }
2025-12-12T11:57:09.591202Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 77
2025-12-12T11:57:09.596412Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 78 offsets: 77 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.596433Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 78
2025-12-12T11:57:09.598025Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 79 to 79
2025-12-12T11:57:09.599776Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.599793Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 79
2025-12-12T11:57:09.606588Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 79 offsets: 78 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.606621Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 79
2025-12-12T11:57:09.608075Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 80 to 80
2025-12-12T11:57:09.610605Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.610628Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 80
2025-12-12T11:57:09.617854Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 80 offsets: 79 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.617876Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 80
2025-12-12T11:57:09.620145Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 81 to 81
2025-12-12T11:57:09.622467Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.622489Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 81
2025-12-12T11:57:09.632923Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 82 to 82
2025-12-12T11:57:09.635514Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.635544Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 82
2025-12-12T11:57:09.642553Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 81 offsets: 80 already_written: false write_statistics { persist_duration_ms: 11 }
2025-12-12T11:57:09.642596Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 81
2025-12-12T11:57:09.645501Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 82 offsets: 81 already_written: false write_statistics { persist_duration_ms: 4 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.645525Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 82
2025-12-12T11:57:09.645897Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 83 to 83
2025-12-12T11:57:09.648407Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.648429Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 83
2025-12-12T11:57:09.657075Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 83 offsets: 82 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.657099Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 83
2025-12-12T11:57:09.657828Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 84 to 84
2025-12-12T11:57:09.660419Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.660448Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 84
2025-12-12T11:57:09.670300Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 84 offsets: 83 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.670340Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 84
2025-12-12T11:57:09.670849Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 85 to 85
2025-12-12T11:57:09.673386Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.673412Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 85
2025-12-12T11:57:09.681820Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 86 to 86
2025-12-12T11:57:09.684331Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.684354Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 86
2025-12-12T11:57:09.686085Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 85 offsets: 84 already_written: false write_statistics { persist_duration_ms: 9 }
2025-12-12T11:57:09.686118Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 85
2025-12-12T11:57:09.691028Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 86 offsets: 85 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.691064Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 86
2025-12-12T11:57:09.693876Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 87 to 87
2025-12-12T11:57:09.696413Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.696439Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 87
2025-12-12T11:57:09.704000Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 87 offsets: 86 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.704024Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 87
2025-12-12T11:57:09.705594Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 88 to 88
2025-12-12T11:57:09.707972Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.707987Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 88
2025-12-12T11:57:09.715205Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 88 offsets: 87 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.715239Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 88
2025-12-12T11:57:09.716833Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 89 to 89
2025-12-12T11:57:09.719112Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.719134Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 89
2025-12-12T11:57:09.729317Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 90 to 90
2025-12-12T11:57:09.731584Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.731605Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 90
2025-12-12T11:57:09.742420Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 91 to 91
2025-12-12T11:57:09.744947Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.744968Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 91
2025-12-12T11:57:09.748695Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 89 offsets: 88 already_written: false write_statistics { persist_duration_ms: 15 }
2025-12-12T11:57:09.748714Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 89
2025-12-12T11:57:09.752608Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 90 offsets: 89 already_written: false write_statistics { persist_duration_ms: 9 queued_in_partition_duration_ms: 7 }
2025-12-12T11:57:09.752636Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 90
2025-12-12T11:57:09.754888Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 92 to 92
2025-12-12T11:57:09.757409Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.757432Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 92
2025-12-12T11:57:09.758877Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 91 offsets: 90 already_written: false write_statistics { persist_duration_ms: 3 queued_in_partition_duration_ms: 2 }
2025-12-12T11:57:09.758910Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 91
2025-12-12T11:57:09.764651Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 92 offsets: 91 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.764676Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 92
2025-12-12T11:57:09.767349Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 93 to 93
2025-12-12T11:57:09.769891Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.769918Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 93
2025-12-12T11:57:09.779494Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 94 to 94
2025-12-12T11:57:09.782063Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.782092Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 94
2025-12-12T11:57:09.792368Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 95 to 95
2025-12-12T11:57:09.794814Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.794836Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 95
2025-12-12T11:57:09.796257Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 93 offsets: 92 already_written: false write_statistics { persist_duration_ms: 13 }
2025-12-12T11:57:09.796279Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 93
2025-12-12T11:57:09.798875Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 94 offsets: 93 already_written: false write_statistics { persist_duration_ms: 8 queued_in_partition_duration_ms: 4 }
2025-12-12T11:57:09.798891Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 94
2025-12-12T11:57:09.801284Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 95 offsets: 94 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.801299Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 95
2025-12-12T11:57:09.805511Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 96 to 96
2025-12-12T11:57:09.807917Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.807940Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 96
2025-12-12T11:57:09.815844Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 96 offsets: 95 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.815874Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 96
2025-12-12T11:57:09.819429Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 97 to 97
2025-12-12T11:57:09.821994Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.822029Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 97
2025-12-12T11:57:09.831853Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 98 to 98
2025-12-12T11:57:09.833780Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.833807Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 98
2025-12-12T11:57:09.835416Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 97 offsets: 96 already_written: false write_statistics { persist_duration_ms: 9 }
2025-12-12T11:57:09.835434Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 97
2025-12-12T11:57:09.840560Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 98 offsets: 97 already_written: false write_statistics { persist_duration_ms: 3 }
2025-12-12T11:57:09.840596Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 98
2025-12-12T11:57:09.842562Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 99 to 99
2025-12-12T11:57:09.845006Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.845026Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 99
2025-12-12T11:57:09.852454Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 99 offsets: 98 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.852484Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 99
2025-12-12T11:57:09.853733Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write 1 messages with Id from 100 to 100
2025-12-12T11:57:09.856146Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: try to update token
2025-12-12T11:57:09.856164Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Send 1 message(s) (0 left), first sequence number is 100
2025-12-12T11:57:09.857906Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: close. Timeout = 18446744073709551 ms
2025-12-12T11:57:09.863589Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session got write response: sequence_numbers: 100 offsets: 99 already_written: false write_statistics { persist_duration_ms: 4 }
2025-12-12T11:57:09.863629Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: acknoledged message 100
2025-12-12T11:57:09.958025Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session will now close
2025-12-12T11:57:09.958058Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: aborting
2025-12-12T11:57:09.958336Z :INFO: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: gracefully shut down, all writes complete
Session was created
2025-12-12T11:57:09.958414Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Starting read session
2025-12-12T11:57:09.958419Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Starting single session
2025-12-12T11:57:09.958526Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session is aborting and will not restart
2025-12-12T11:57:09.958649Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In Reconnect, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-12-12T11:57:09.958653Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] New values: ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-12-12T11:57:09.958656Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:09.958953Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Successfully connected. Initializing session
2025-12-12T11:57:09.959752Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got InitResponse. ReadSessionId: BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1
2025-12-12T11:57:09.959773Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-12-12T11:57:09.959859Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:09.961327Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic". Partition: 0. Read offset: (NULL)
2025-12-12T11:57:09.961430Z :DEBUG: [local] 0x00005287FF752310 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 StartPartitionSession 1 nodeId=1
2025-12-12T11:57:09.961452Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
2025-12-12T11:57:09.961704Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:09.961713Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:09.961728Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 SendStartRequestImpl bail out 1
2025-12-12T11:57:09.961755Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:09.961827Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession send message = init_request { session_id: "BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1" topics_read_settings { path: "sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic" } consumer: "BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer" }
2025-12-12T11:57:09.962451Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS init_response { }
2025-12-12T11:57:09.962461Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Got InitResponse 
2025-12-12T11:57:09.962465Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:09.962476Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:09.962482Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:09.962881Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = status: SUCCESS start_direct_read_partition_session_response { partition_session_id: 1 generation: 1 }
2025-12-12T11:57:09.962894Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Got StartDirectReadPartitionSessionResponse partition_session_id: 1 generation: 1
2025-12-12T11:57:10.046285Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 1 firstOffset = 0 lastOffset = 9
2025-12-12T11:57:10.046312Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
2025-12-12T11:57:10.046581Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 22529553, now ReadSizeBudget = 0, ReadSizeServerDelta = -22005265
2025-12-12T11:57:10.046680Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T11:57:10.046708Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 22529553 to budget
2025-12-12T11:57:10.049317Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T11:57:10.049954Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.050033Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T11:57:10.050071Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.050410Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T11:57:10.051018Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.051069Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-2)
2025-12-12T11:57:10.051085Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.051463Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-12-12T11:57:10.052034Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.052088Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (3-3)
2025-12-12T11:57:10.052105Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.052467Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (3-3)
2025-12-12T11:57:10.053001Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.053038Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (4-4)
2025-12-12T11:57:10.053049Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.053393Z :DEBUG: [local] Take Data. Partition 0. Read: {4, 0} (4-4)
2025-12-12T11:57:10.053932Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.053994Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (5-5)
2025-12-12T11:57:10.054011Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.054286Z :DEBUG: [local] Take Data. Partition 0. Read: {5, 0} (5-5)
2025-12-12T11:57:10.054778Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.054816Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-6)
2025-12-12T11:57:10.054826Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.055127Z :DEBUG: [local] Take Data. Partition 0. Read: {6, 0} (6-6)
2025-12-12T11:57:10.055695Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.055766Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (7-7)
2025-12-12T11:57:10.055780Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.056130Z :DEBUG: [local] Take Data. Partition 0. Read: {7, 0} (7-7)
2025-12-12T11:57:10.056737Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.056778Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (8-8)
2025-12-12T11:57:10.056789Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.057075Z :DEBUG: [local] Take Data. Partition 0. Read: {8, 0} (8-8)
2025-12-12T11:57:10.057640Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.057689Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (9-9)
2025-12-12T11:57:10.057701Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.058033Z :DEBUG: [local] Take Data. Partition 0. Read: {9, 0} (9-9)
2025-12-12T11:57:10.058630Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.058666Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 22529553, ReadSizeServerDelta = -22005265
2025-12-12T11:57:10.058865Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.058876Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.079131Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 2 firstOffset = 10 lastOffset = 13
2025-12-12T11:57:10.079153Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=2. Got DirectReadResponse 2
2025-12-12T11:57:10.079337Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.079401Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (10-10)
2025-12-12T11:57:10.079417Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.079742Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-12-12T11:57:10.080305Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.080357Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (11-11)
2025-12-12T11:57:10.080373Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.080690Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (11-11)
2025-12-12T11:57:10.081217Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.081257Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (12-12)
2025-12-12T11:57:10.081269Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.081573Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (12-12)
2025-12-12T11:57:10.082069Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.082099Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (13-13)
2025-12-12T11:57:10.082109Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.082415Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (13-13)
2025-12-12T11:57:10.082897Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.082909Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.083053Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.083063Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.101336Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 3 firstOffset = 14 lastOffset = 17
2025-12-12T11:57:10.101358Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=3. Got DirectReadResponse 3
2025-12-12T11:57:10.101546Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.101629Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (14-14)
2025-12-12T11:57:10.101648Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.101980Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (14-14)
2025-12-12T11:57:10.102515Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.102557Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (15-15)
2025-12-12T11:57:10.102570Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.102890Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (15-15)
2025-12-12T11:57:10.103415Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.103498Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (16-16)
2025-12-12T11:57:10.103510Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.103838Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (16-16)
2025-12-12T11:57:10.104371Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.104411Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (17-17)
2025-12-12T11:57:10.104423Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.104721Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (17-17)
2025-12-12T11:57:10.105219Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.105231Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.105378Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.105388Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.119000Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 4 firstOffset = 18 lastOffset = 20
2025-12-12T11:57:10.119024Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=4. Got DirectReadResponse 4
2025-12-12T11:57:10.119204Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.119276Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (18-18)
2025-12-12T11:57:10.119296Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.119601Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (18-18)
2025-12-12T11:57:10.120148Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.120202Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (19-19)
2025-12-12T11:57:10.120223Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.120543Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (19-19)
2025-12-12T11:57:10.121051Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.121090Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (20-20)
2025-12-12T11:57:10.121103Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.121418Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (20-20)
2025-12-12T11:57:10.121981Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.121994Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.122123Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.122132Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.140663Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 5 firstOffset = 21 lastOffset = 24
2025-12-12T11:57:10.140686Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=5. Got DirectReadResponse 5
2025-12-12T11:57:10.140850Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.140918Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (21-21)
2025-12-12T11:57:10.140933Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.141296Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (21-21)
2025-12-12T11:57:10.141861Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.141906Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (22-22)
2025-12-12T11:57:10.141917Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.142245Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (22-22)
2025-12-12T11:57:10.142797Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.142830Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (23-23)
2025-12-12T11:57:10.142854Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.143172Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (23-23)
2025-12-12T11:57:10.143672Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.143708Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (24-24)
2025-12-12T11:57:10.143715Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.144035Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (24-24)
2025-12-12T11:57:10.144639Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.144655Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.144832Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.144856Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.159417Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 6 firstOffset = 25 lastOffset = 27
2025-12-12T11:57:10.159441Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=6. Got DirectReadResponse 6
2025-12-12T11:57:10.159610Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.159678Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (25-25)
2025-12-12T11:57:10.159696Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.160006Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (25-25)
2025-12-12T11:57:10.160619Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.160666Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (26-26)
2025-12-12T11:57:10.160682Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.161017Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (26-26)
2025-12-12T11:57:10.161549Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.161585Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (27-27)
2025-12-12T11:57:10.161595Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.161896Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (27-27)
2025-12-12T11:57:10.162431Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.162442Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.162575Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.162585Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.180788Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 7 firstOffset = 28 lastOffset = 31
2025-12-12T11:57:10.180806Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=7. Got DirectReadResponse 7
2025-12-12T11:57:10.180963Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.181032Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (28-28)
2025-12-12T11:57:10.181050Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.181376Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (28-28)
2025-12-12T11:57:10.181999Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.182038Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (29-29)
2025-12-12T11:57:10.182047Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.182381Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (29-29)
2025-12-12T11:57:10.182946Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.182991Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (30-30)
2025-12-12T11:57:10.183002Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.183339Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (30-30)
2025-12-12T11:57:10.183884Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.183916Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (31-31)
2025-12-12T11:57:10.183923Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.184278Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (31-31)
2025-12-12T11:57:10.184862Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.184878Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.185038Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.185048Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.197441Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 8 firstOffset = 32 lastOffset = 34
2025-12-12T11:57:10.197465Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=8. Got DirectReadResponse 8
2025-12-12T11:57:10.197658Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.197730Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (32-32)
2025-12-12T11:57:10.197748Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.198104Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (32-32)
2025-12-12T11:57:10.198712Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.198749Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (33-33)
2025-12-12T11:57:10.198759Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.199088Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (33-33)
2025-12-12T11:57:10.199658Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.199699Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (34-34)
2025-12-12T11:57:10.199721Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.200023Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (34-34)
2025-12-12T11:57:10.200641Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.200656Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.200823Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.200834Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.219043Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 9 firstOffset = 35 lastOffset = 38
2025-12-12T11:57:10.219062Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=9. Got DirectReadResponse 9
2025-12-12T11:57:10.219218Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.219294Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (35-35)
2025-12-12T11:57:10.219312Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.219631Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (35-35)
2025-12-12T11:57:10.220237Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.220287Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (36-36)
2025-12-12T11:57:10.220298Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.220599Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (36-36)
2025-12-12T11:57:10.221119Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.221157Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (37-37)
2025-12-12T11:57:10.221167Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.221536Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (37-37)
2025-12-12T11:57:10.222079Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.222125Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (38-38)
2025-12-12T11:57:10.222139Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.222477Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (38-38)
2025-12-12T11:57:10.223018Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.223034Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.223205Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.223216Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.237088Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 10 firstOffset = 39 lastOffset = 41
2025-12-12T11:57:10.237109Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=10. Got DirectReadResponse 10
2025-12-12T11:57:10.237271Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.237383Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (39-39)
2025-12-12T11:57:10.237423Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.237773Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (39-39)
2025-12-12T11:57:10.238300Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.238354Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (40-40)
2025-12-12T11:57:10.238367Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.238670Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (40-40)
2025-12-12T11:57:10.239188Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.239232Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (41-41)
2025-12-12T11:57:10.239247Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.239541Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (41-41)
2025-12-12T11:57:10.240290Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.240308Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.240510Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.240527Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.256044Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 11 firstOffset = 42 lastOffset = 45
2025-12-12T11:57:10.256065Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=11. Got DirectReadResponse 11
2025-12-12T11:57:10.256258Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.256350Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (42-42)
2025-12-12T11:57:10.256376Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.256687Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (42-42)
2025-12-12T11:57:10.257279Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.257333Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (43-43)
2025-12-12T11:57:10.257345Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.257660Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (43-43)
2025-12-12T11:57:10.258178Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.258215Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (44-44)
2025-12-12T11:57:10.258230Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.258539Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (44-44)
2025-12-12T11:57:10.259058Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.259107Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (45-45)
2025-12-12T11:57:10.259120Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.259413Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (45-45)
2025-12-12T11:57:10.260016Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.260042Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.260241Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.260254Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.276983Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 12 firstOffset = 46 lastOffset = 49
2025-12-12T11:57:10.277010Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=12. Got DirectReadResponse 12
2025-12-12T11:57:10.277199Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.277280Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (46-46)
2025-12-12T11:57:10.277300Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.277614Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (46-46)
2025-12-12T11:57:10.278158Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.278214Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (47-47)
2025-12-12T11:57:10.278228Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.278530Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (47-47)
2025-12-12T11:57:10.278997Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.279033Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (48-48)
2025-12-12T11:57:10.279044Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.279475Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (48-48)
2025-12-12T11:57:10.279965Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.279994Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (49-49)
2025-12-12T11:57:10.280002Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.280352Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (49-49)
2025-12-12T11:57:10.280878Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.280891Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.281045Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.281053Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.293876Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 13 firstOffset = 50 lastOffset = 52
2025-12-12T11:57:10.293896Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=13. Got DirectReadResponse 13
2025-12-12T11:57:10.294056Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.294115Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (50-50)
2025-12-12T11:57:10.294134Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.294461Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (50-50)
2025-12-12T11:57:10.295022Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.295064Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (51-51)
2025-12-12T11:57:10.295079Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.295411Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (51-51)
2025-12-12T11:57:10.295956Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.295993Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (52-52)
2025-12-12T11:57:10.296004Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.296331Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (52-52)
2025-12-12T11:57:10.296869Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.296879Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.297001Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.297009Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.314951Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 14 firstOffset = 53 lastOffset = 56
2025-12-12T11:57:10.314976Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=14. Got DirectReadResponse 14
2025-12-12T11:57:10.315185Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.315260Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (53-53)
2025-12-12T11:57:10.315279Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.315639Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (53-53)
2025-12-12T11:57:10.316265Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.316303Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (54-54)
2025-12-12T11:57:10.316312Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.316637Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (54-54)
2025-12-12T11:57:10.317153Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.317189Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (55-55)
2025-12-12T11:57:10.317197Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.317506Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (55-55)
2025-12-12T11:57:10.318015Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.318047Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (56-56)
2025-12-12T11:57:10.318052Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.318362Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (56-56)
2025-12-12T11:57:10.318855Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.318865Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.319010Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.319018Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.333146Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 15 firstOffset = 57 lastOffset = 59
2025-12-12T11:57:10.333171Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=15. Got DirectReadResponse 15
2025-12-12T11:57:10.333346Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.333439Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (57-57)
2025-12-12T11:57:10.333458Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.333797Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (57-57)
2025-12-12T11:57:10.334362Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.334401Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (58-58)
2025-12-12T11:57:10.334411Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.334729Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (58-58)
2025-12-12T11:57:10.335291Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.335324Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (59-59)
2025-12-12T11:57:10.335332Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.335638Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (59-59)
2025-12-12T11:57:10.336203Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.336231Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.336382Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.336394Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.354403Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 16 firstOffset = 60 lastOffset = 63
2025-12-12T11:57:10.354430Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=16. Got DirectReadResponse 16
2025-12-12T11:57:10.354634Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.354708Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (60-60)
2025-12-12T11:57:10.354727Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.355047Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (60-60)
2025-12-12T11:57:10.355610Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.355653Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (61-61)
2025-12-12T11:57:10.355665Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.355998Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (61-61)
2025-12-12T11:57:10.356581Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.356632Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (62-62)
2025-12-12T11:57:10.356645Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.356953Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (62-62)
2025-12-12T11:57:10.357470Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.357506Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (63-63)
2025-12-12T11:57:10.357513Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.357826Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (63-63)
2025-12-12T11:57:10.358358Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.358371Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.358519Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.358543Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.370989Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 17 firstOffset = 64 lastOffset = 66
2025-12-12T11:57:10.371015Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=17. Got DirectReadResponse 17
2025-12-12T11:57:10.371181Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.371247Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (64-64)
2025-12-12T11:57:10.371266Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.371595Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (64-64)
2025-12-12T11:57:10.372155Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.372216Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (65-65)
2025-12-12T11:57:10.372229Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.372512Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (65-65)
2025-12-12T11:57:10.373054Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.373104Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (66-66)
2025-12-12T11:57:10.373116Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.373429Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (66-66)
2025-12-12T11:57:10.373994Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.374005Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.374130Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.374144Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.391968Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 18 firstOffset = 67 lastOffset = 70
2025-12-12T11:57:10.391992Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=18. Got DirectReadResponse 18
2025-12-12T11:57:10.392226Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.392290Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (67-67)
2025-12-12T11:57:10.392300Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.392623Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (67-67)
2025-12-12T11:57:10.393162Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.393219Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (68-68)
2025-12-12T11:57:10.393233Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.393571Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (68-68)
2025-12-12T11:57:10.394119Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.394159Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (69-69)
2025-12-12T11:57:10.394171Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.394482Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (69-69)
2025-12-12T11:57:10.395009Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.395058Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (70-70)
2025-12-12T11:57:10.395069Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.395367Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (70-70)
2025-12-12T11:57:10.395902Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.395915Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.396081Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.396091Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.410675Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 19 firstOffset = 71 lastOffset = 73
2025-12-12T11:57:10.410700Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=19. Got DirectReadResponse 19
2025-12-12T11:57:10.410880Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.410950Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (71-71)
2025-12-12T11:57:10.410970Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.411291Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (71-71)
2025-12-12T11:57:10.411903Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.411950Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (72-72)
2025-12-12T11:57:10.411963Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.412283Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (72-72)
2025-12-12T11:57:10.412845Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.412878Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (73-73)
2025-12-12T11:57:10.412886Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.413191Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (73-73)
2025-12-12T11:57:10.413724Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.413735Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.413877Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.413888Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.431841Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 20 firstOffset = 74 lastOffset = 77
2025-12-12T11:57:10.431864Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=20. Got DirectReadResponse 20
2025-12-12T11:57:10.432050Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.432119Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (74-74)
2025-12-12T11:57:10.432139Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.432504Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (74-74)
2025-12-12T11:57:10.433090Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.433134Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (75-75)
2025-12-12T11:57:10.433147Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.433449Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (75-75)
2025-12-12T11:57:10.434035Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.434083Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (76-76)
2025-12-12T11:57:10.434095Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.434439Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (76-76)
2025-12-12T11:57:10.434970Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.435010Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (77-77)
2025-12-12T11:57:10.435019Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.435318Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (77-77)
2025-12-12T11:57:10.435868Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.435882Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.436034Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.436044Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.457953Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 21 firstOffset = 78 lastOffset = 81
2025-12-12T11:57:10.457992Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=21. Got DirectReadResponse 21
2025-12-12T11:57:10.458327Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.458451Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (78-78)
2025-12-12T11:57:10.458480Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.458871Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (78-78)
2025-12-12T11:57:10.459586Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.459654Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (79-79)
2025-12-12T11:57:10.459663Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.460055Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (79-79)
2025-12-12T11:57:10.460702Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.460748Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (80-80)
2025-12-12T11:57:10.460763Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.461152Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (80-80)
2025-12-12T11:57:10.461833Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.461881Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (81-81)
2025-12-12T11:57:10.461898Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.462291Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (81-81)
2025-12-12T11:57:10.463044Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.463070Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.463288Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.463300Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.477184Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 22 firstOffset = 82 lastOffset = 84
2025-12-12T11:57:10.477214Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=22. Got DirectReadResponse 22
2025-12-12T11:57:10.477418Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.477501Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (82-82)
2025-12-12T11:57:10.477521Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.477871Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (82-82)
2025-12-12T11:57:10.478454Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.478509Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (83-83)
2025-12-12T11:57:10.478535Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.479020Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (83-83)
2025-12-12T11:57:10.479630Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.479671Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (84-84)
2025-12-12T11:57:10.479684Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.480007Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (84-84)
2025-12-12T11:57:10.480626Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.480641Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.480802Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.480810Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.503729Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 23 firstOffset = 85 lastOffset = 88
2025-12-12T11:57:10.503752Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=23. Got DirectReadResponse 23
2025-12-12T11:57:10.503932Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.504021Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (85-85)
2025-12-12T11:57:10.504037Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.504379Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (85-85)
2025-12-12T11:57:10.505055Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.505109Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (86-86)
2025-12-12T11:57:10.505133Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.505509Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (86-86)
2025-12-12T11:57:10.506115Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.506161Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (87-87)
2025-12-12T11:57:10.506185Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.506503Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (87-87)
2025-12-12T11:57:10.507036Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.507074Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (88-88)
2025-12-12T11:57:10.507085Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.507430Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (88-88)
2025-12-12T11:57:10.507968Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.507981Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.508147Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.508156Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.523963Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 24 firstOffset = 89 lastOffset = 91
2025-12-12T11:57:10.523989Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=24. Got DirectReadResponse 24
2025-12-12T11:57:10.524166Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.524277Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (89-89)
2025-12-12T11:57:10.524297Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.524604Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (89-89)
2025-12-12T11:57:10.525206Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.525265Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (90-90)
2025-12-12T11:57:10.525276Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.525605Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (90-90)
2025-12-12T11:57:10.526128Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.526168Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (91-91)
2025-12-12T11:57:10.526180Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.526474Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (91-91)
2025-12-12T11:57:10.527007Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.527020Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.527161Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.527172Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.546016Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 25 firstOffset = 92 lastOffset = 95
2025-12-12T11:57:10.546038Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=25. Got DirectReadResponse 25
2025-12-12T11:57:10.546247Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 9011841, now ReadSizeBudget = 0, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.546321Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (92-92)
2025-12-12T11:57:10.546343Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 9011841 to budget
2025-12-12T11:57:10.546692Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (92-92)
2025-12-12T11:57:10.547382Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.547451Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (93-93)
2025-12-12T11:57:10.547465Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.547832Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (93-93)
2025-12-12T11:57:10.548552Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.548610Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (94-94)
2025-12-12T11:57:10.548624Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.548984Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (94-94)
2025-12-12T11:57:10.549712Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.549762Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (95-95)
2025-12-12T11:57:10.549776Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.550103Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (95-95)
2025-12-12T11:57:10.550625Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.550638Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 9011841, ReadSizeServerDelta = -8487553
2025-12-12T11:57:10.550839Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.550849Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.564357Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 26 firstOffset = 96 lastOffset = 98
2025-12-12T11:57:10.564379Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=26. Got DirectReadResponse 26
2025-12-12T11:57:10.564560Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 6758889, now ReadSizeBudget = 0, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.564619Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (96-96)
2025-12-12T11:57:10.564636Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 6758889 to budget
2025-12-12T11:57:10.564958Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (96-96)
2025-12-12T11:57:10.565527Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.565571Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (97-97)
2025-12-12T11:57:10.565585Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.565907Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (97-97)
2025-12-12T11:57:10.566375Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.566424Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (98-98)
2025-12-12T11:57:10.566438Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.566743Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (98-98)
2025-12-12T11:57:10.567217Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.567227Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 6758889, ReadSizeServerDelta = -6234601
2025-12-12T11:57:10.567352Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.567378Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.573863Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 XXXXX subsession got message = DirectReadResponse partitionSessionId = 1 partitionId = 0 directReadId = 27 firstOffset = 99 lastOffset = 99
2025-12-12T11:57:10.573886Z :DEBUG: [local] 0x00005287FF6073A0 TDirectReadSession ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 NodeId=1 Waiting for NextDirectReadId=27. Got DirectReadResponse 27
2025-12-12T11:57:10.574029Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Got ReadResponse, serverBytesSize = 2252985, now ReadSizeBudget = 0, ReadSizeServerDelta = -1728697
2025-12-12T11:57:10.574106Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (99-99)
2025-12-12T11:57:10.574131Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 2252985 to budget
2025-12-12T11:57:10.574436Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (99-99)
2025-12-12T11:57:10.575005Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] The application data is transferred to the client. Number of messages 1, size 2252800 bytes
2025-12-12T11:57:10.575015Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Closing read session. Close timeout: 0.010000s
2025-12-12T11:57:10.575022Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] In ContinueReadingDataImpl, ReadSizeBudget = 2252985, ReadSizeServerDelta = -1728697
2025-12-12T11:57:10.575207Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-12-12T11:57:10.575220Z :DEBUG: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] [] Returning serverBytesSize = 0 to budget
2025-12-12T11:57:10.575223Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic:0:1:99:0
2025-12-12T11:57:10.575236Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Counters: { Errors: 0 CurrentSessionLifetimeMs: 616 BytesRead: 225280000 MessagesRead: 100 BytesReadCompressed: 225280000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:10.575549Z :DEBUG: [local] 0x00005287FF752310 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 Close
2025-12-12T11:57:10.575742Z :DEBUG: [local] 0x00005287FF752310 TDirectReadSessionManager ServerSessionId=BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression-test-consumer_1_5_17368178726069350626_v1 Close
2025-12-12T11:57:10.580144Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Closing read session. Close timeout: 0.000000s
2025-12-12T11:57:10.580197Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:sdk_tests/BasicUsage-DirectRead_WriteAndReadSomeMessagesWithSyncCompression/test-topic:0:1:99:0
2025-12-12T11:57:10.580221Z :INFO: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Counters: { Errors: 0 CurrentSessionLifetimeMs: 621 BytesRead: 225280000 MessagesRead: 100 BytesReadCompressed: 225280000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:10.580246Z :NOTICE: [local] [local] [8398d463-89363b89-5aec4b15-b7cdb900] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T11:57:10.592324Z :DEBUG: [local] MessageGroupId [test-message_group_id] SessionId [test-message_group_id|ab79821d-130a3d82-9620ef49-df95eb49_0] Write session: destroy
