2025-12-12T11:57:52.243386Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 Reconnecting direct read session to node 1 in 0.000000s
XXXXX AddServerResponse 1 init_response {
}
2025-12-12T11:57:52.243498Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 Successfully connected. Initializing session
2025-12-12T11:57:52.243539Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 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.243578Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 XXXXX subsession got message = init_response { }
2025-12-12T11:57:52.243583Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 Got InitResponse 
XXXXX Read 1 
2025-12-12T11:57:52.244116Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 AddPartitionSession 1
2025-12-12T11:57:52.244124Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 SendStartRequestImpl partitionSession.State=0 delayedCall=0
2025-12-12T11:57:52.244139Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 SendStartRequestImpl send request start_direct_read_partition_session_request { partition_session_id: 1 generation: 3 }
2025-12-12T11:57:52.244142Z :DEBUG: 0x000053477FBC0020 TDirectReadSession ServerSessionId=server-session-id-1 NodeId=1 XXXXX subsession send message = start_direct_read_partition_session_request { partition_session_id: 1 generation: 3 }
XXXXX Validate
