2025-12-12T11:57:52.206788Z :DEBUG: [db] [client-session-id-1] [] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.206801Z :DEBUG: [db] [client-session-id-1] [] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.206806Z :DEBUG: [db] [client-session-id-1] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T11:57:52.206896Z :DEBUG: [db] [client-session-id-1] [] Successfully connected. Initializing session
2025-12-12T11:57:52.207039Z :INFO: [db] [client-session-id-1] [] Got InitResponse. ReadSessionId: server-session-id-1
2025-12-12T11:57:52.207056Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T11:57:52.207072Z :DEBUG: [db] [client-session-id-1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
2025-12-12T11:57:52.207213Z :INFO: [db] [client-session-id-1] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "". Partition: 1. Read offset: (NULL)
2025-12-12T11:57:52.207236Z :DEBUG: 0x000053477F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 StartPartitionSession 2 nodeId=3
2025-12-12T11:57:52.207249Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Reconnecting direct read session to node 3 in 0.000000s
2025-12-12T11:57:52.207320Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 AddPartitionSession 2
2025-12-12T11:57:52.207325Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:52.207328Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl bail out 1
XXXXX AddServerResponse 1 init_response {
}
2025-12-12T11:57:52.207361Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Successfully connected. Initializing session
XXXXX AddServerResponse 1 start_direct_read_partition_session_response {
  partition_session_id: 2
}
XXXXX AddServerResponse 1 direct_read_response {
  partition_session_id: 2
  direct_read_id: 1
  partition_data {
    partition_session_id: 2
  }
  bytes_size: 12345
}
2025-12-12T11:57:52.207414Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession send message = init_request { session_id: "server-session-id-1" topics_read_settings { path: "TestTopic" } consumer: "TestConsumer" }
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 init_response {
}
2025-12-12T11:57:52.207476Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = init_response { }
2025-12-12T11:57:52.207482Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got InitResponse 
2025-12-12T11:57:52.207487Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:52.207508Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 2 generation: 4 }
2025-12-12T11:57:52.207514Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 2 generation: 4 }
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 start_direct_read_partition_session_response {
  partition_session_id: 2
}
2025-12-12T11:57:52.207541Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = start_direct_read_partition_session_response { partition_session_id: 2 }
2025-12-12T11:57:52.207545Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse partition_session_id: 2
2025-12-12T11:57:52.207549Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Got StartDirectReadPartitionSessionResponse for wrong generation (expected 4, got 0) partition_session_id=2
XXXXX Read 1 
XXXXX Read 2 
XXXXX Read 3 direct_read_response {
  partition_session_id: 2
  direct_read_id: 1
  partition_data {
    partition_session_id: 2
  }
  bytes_size: 12345
}
2025-12-12T11:57:52.207568Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 XXXXX subsession got message = DirectReadResponse EMPTY
2025-12-12T11:57:52.207571Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=3 Waiting for NextDirectReadId=1. Got DirectReadResponse 1
XXXXX Read 1 
2025-12-12T11:57:52.207604Z :DEBUG: [db] [client-session-id-1] [] In ContinueReadingDataImpl, ReadSizeBudget = 12345, ReadSizeServerDelta = 52416455
2025-12-12T11:57:52.207614Z :DEBUG: [db] [client-session-id-1] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 52428800
XXXXX Validate
2025-12-12T11:57:52.207658Z :DEBUG: 0x000053477F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 Close
2025-12-12T11:57:52.207667Z :DEBUG: 0x000053477F740510 TDirectReadSessionManager ServerSessionId=server-session-id-1 Close
