diff --git a/ydb/topic.py b/ydb/topic.py index d598fb7d..454aee3c 100644 --- a/ydb/topic.py +++ b/ydb/topic.py @@ -11,6 +11,7 @@ "TopicMeteringMode", "TopicReader", "TopicReaderAsyncIO", + "TopicReaderMessage", "TopicReaderSelector", "TopicReaderSettings", "TopicReaderPartitionExpiredError", @@ -32,6 +33,8 @@ from . import driver +from ._topic_reader.datatypes import PublicMessage as TopicReaderMessage + from ._topic_reader.topic_reader import ( PublicReaderSettings as TopicReaderSettings, PublicTopicSelector as TopicReaderSelector,