10#include <ydb-cpp-sdk/client/topic/client.h>
12USERVER_NAMESPACE_BEGIN
29class TopicReadSession
final {
33 explicit TopicReadSession(
34 std::shared_ptr<NYdb::NTopic::IReadSession> read_session);
49 bool Close(std::chrono::milliseconds timeout);
58 std::shared_ptr<NYdb::NTopic::IReadSession> read_session_;
66class TopicClient
final {
70 TopicClient(std::shared_ptr<impl::Driver> driver,
71 impl::TopicSettings settings);
78 const NYdb::NTopic::TAlterTopicSettings& settings);
85 const NYdb::NTopic::TReadSessionSettings& settings);
94 std::shared_ptr<impl::Driver> driver_;
95 NYdb::NTopic::TTopicClient topic_client_;