From 262f8b19bb1721143b212c4083bc656465d59861 Mon Sep 17 00:00:00 2001 From: Timofey Koolin Date: Tue, 31 Oct 2023 08:44:16 +0300 Subject: [PATCH] set default one thread for encode/decode messages --- ydb/topic.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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):