2025-12-12T12:00:53.783018Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T12:00:53.783186Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:53.783212Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:53.784224Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:53.784237Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:53.784242Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:53.784397Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:53.784432Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_1" partition_with_generation { generation: 1 } }
2025-12-12T12:00:53.784526Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:53.791329Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.791355Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540853791 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:53.791383Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0"
2025-12-12T12:00:53.791452Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=1, AckCount=0
2025-12-12T12:00:53.792581Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:53.793639Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.793649Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:53.795340Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=0
2025-12-12T12:00:53.796771Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:53.796962Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.796972Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:53.797969Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T12:00:53.798194Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:00:53.798229Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:00:53.799281Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:53.799292Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:53.799296Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:53.799456Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:00:53.799488Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_3" partition_with_generation { generation: 1 } }
2025-12-12T12:00:53.799577Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:53.805081Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.805141Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 4000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.805154Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=1
2025-12-12T12:00:53.805161Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:53.807055Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.807089Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 3000000 } max_queue_wait_time { nanos: 3000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.807096Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=2
2025-12-12T12:00:53.807099Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:53.807473Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.807486Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540853807 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:53.807501Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0"
2025-12-12T12:00:53.807553Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=1, AckCount=0
2025-12-12T12:00:53.807722Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:53.807865Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.807871Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:53.808529Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=0
2025-12-12T12:00:53.809578Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:53.809727Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.809732Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:53.810297Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Write session: try to update token
2025-12-12T12:00:53.810490Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-12T12:00:53.810530Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-12T12:00:53.816552Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:53.816566Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:53.816572Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:53.816849Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-12T12:00:53.816878Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_2" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-12T12:00:53.816995Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:53.820898Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.820952Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 8000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.820970Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=1
2025-12-12T12:00:53.820974Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:53.822870Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.822886Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540853822 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:53.822906Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0" partition_id: 1
2025-12-12T12:00:53.822963Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=1, AckCount=0
2025-12-12T12:00:53.823128Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:53.823198Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.823259Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 4000000 } min_queue_wait_time { nanos: 2000000 } max_queue_wait_time { nanos: 2000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.823272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=2
2025-12-12T12:00:53.823277Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:53.823290Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.823299Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:53.823985Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=0
2025-12-12T12:00:53.824115Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:53.824272Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.824278Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:53.824884Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Write session: try to update token
2025-12-12T12:00:53.825092Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-12T12:00:53.825126Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-12T12:00:53.826173Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T12:00:53.826183Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:00:53.826187Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:00:53.826364Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-12T12:00:53.826394Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageTable-DirectRead_WriteToTopic_Demo_48/topic_A" producer_id: "test-message_group_id_4" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-12T12:00:53.826482Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:00:53.829874Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.829941Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.829954Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=1
2025-12-12T12:00:53.829962Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:53.831820Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.831862Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.831872Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=2
2025-12-12T12:00:53.831875Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:00:53.833048Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.833065Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540853833 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:00:53.833083Z :INFO: [local]  TraceId []  SessionId []  PartitionId [1]  Generation [1] Write session established. Init response: session_id: "test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0" partition_id: 1
2025-12-12T12:00:53.833152Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=1, AckCount=0
2025-12-12T12:00:53.833334Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:00:53.833490Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.833497Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:00:53.834302Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] OnWrite: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=0
2025-12-12T12:00:53.834457Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:00:53.834594Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:00:53.834599Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:00:53.844019Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.844091Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 8000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.844103Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=1
2025-12-12T12:00:53.844108Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:00:53.845764Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:00:53.845808Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } partition_id: 1 write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { nanos: 2000000 } max_queue_wait_time { nanos: 2000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:00:53.845817Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] OnAck: seqNo=2, txId={ydb://session/3?node_id=1&id=NjM0M2JlNGQtODU4YjgwOTYtZTM0NDgxMGUtOTFmYzA1NTE=, 01kc96yy0n31a438y2ygwrv4vw}, WriteCount=2, AckCount=2
2025-12-12T12:00:53.846007Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:01:23.748314Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:01:23.748329Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-12T12:01:23.748337Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-12T12:01:23.748555Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:01:23.748562Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_2|3b98b4cd-5124c059-19597c8b-765e4e8c_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-12T12:01:23.748832Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:01:23.748838Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:01:23.748843Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:01:23.749001Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:01:23.749011Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:01:23.749024Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-12-12T12:01:23.749040Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_3|60c3060f-d9c4d2a7-f2ffbfd7-d428e07a_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:01:23.749334Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:01:23.749346Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-12T12:01:23.749351Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-12T12:01:23.749477Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:01:23.749482Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_4|17cfc310-bacd3b39-1ae7af14-4d498822_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-12T12:01:23.749628Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:01:23.749630Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:01:23.749633Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:01:23.749696Z :INFO: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:01:23.749700Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id_1|2368519a-382d79e6-2ec6de6a-99a2bc0_0]  PartitionId [0]  Generation [1] Write session: destroy
