diff --git a/ydb/topic.py b/ydb/topic.py index 6843eb68..2175af47 100644 --- a/ydb/topic.py +++ b/ydb/topic.py @@ -387,7 +387,11 @@ def _check_closed(self): @dataclass class TopicClientSettings: - encode_decode_threads_count: int = 4 + # ATTENTION + # When set the encode_decode_threads_count - all custom encoders/decoders for topic reader/writer + # MUST be thread-safe + # because they will be called from parallel threads + encode_decode_threads_count: int = 1 class TopicError(issues.Error):