Skip to content

Commit f5099d3

Browse files
committed
make auto_partitioning_support enabled by default
1 parent 818acdd commit f5099d3

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

ydb/_topic_reader/topic_reader.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class PublicReaderSettings:
4545
consumer: str
4646
topic: TopicSelectorTypes
4747
buffer_size_bytes: int = 50 * 1024 * 1024
48-
auto_partitioning_support: bool = False
48+
auto_partitioning_support: bool = True
4949

5050
decoders: Union[Mapping[int, Callable[[bytes], bytes]], None] = None
5151
"""decoders: map[codec_code] func(encoded_bytes)->decoded_bytes"""

ydb/topic.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ def reader(
236236
# custom decoder executor for call builtin and custom decoders. If None - use shared executor pool.
237237
# if max_worker in the executor is 1 - then decoders will be called from the thread without parallel
238238
decoder_executor: Optional[concurrent.futures.Executor] = None,
239-
auto_partitioning_support: Optional[bool] = False, # Auto partitioning feature flag. Default - False.
239+
auto_partitioning_support: Optional[bool] = True, # Auto partitioning feature flag. Default - True.
240240
) -> TopicReaderAsyncIO:
241241

242242
if not decoder_executor:
@@ -446,7 +446,7 @@ def reader(
446446
# custom decoder executor for call builtin and custom decoders. If None - use shared executor pool.
447447
# if max_worker in the executor is 1 - then decoders will be called from the thread without parallel
448448
decoder_executor: Optional[concurrent.futures.Executor] = None, # default shared client executor pool
449-
auto_partitioning_support: Optional[bool] = False, # Auto partitioning feature flag. Default - False.
449+
auto_partitioning_support: Optional[bool] = True, # Auto partitioning feature flag. Default - True.
450450
) -> TopicReader:
451451
if not decoder_executor:
452452
decoder_executor = self._executor

0 commit comments

Comments
 (0)