diff options
| author | Aleksandr Petrikhin <shmeleine@gmail.com> | 2022-06-30 17:59:10 +0300 |
|---|---|---|
| committer | Aleksandr Petrikhin <shmeleine@gmail.com> | 2022-06-30 17:59:10 +0300 |
| commit | ccf31faee2bc0c051b65ed5899060bd597b22c70 (patch) | |
| tree | 2b27a8206f01ac3e121c8569284854cd88a8e1b9 | |
| parent | 1d8f8dfd93dc506a0fd6a696eda1cf149afdb1f8 (diff) | |
| download | ydb-ccf31faee2bc0c051b65ed5899060bd597b22c70.tar.gz | |
LOGBROKER-7581 add default message size to actor_persqueue
ref:eec3f2edff3511a21c1c852ccb300a0126255aef
| -rw-r--r-- | ydb/core/persqueue/actor_persqueue_client_iface.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/persqueue/actor_persqueue_client_iface.h b/ydb/core/persqueue/actor_persqueue_client_iface.h index 1bf0ed9a4c..2588e1ec3e 100644 --- a/ydb/core/persqueue/actor_persqueue_client_iface.h +++ b/ydb/core/persqueue/actor_persqueue_client_iface.h @@ -13,6 +13,8 @@ namespace NKikimr::NPQ { +constexpr ui64 MaxMessageSize = 150_MB; + class IPersQueueMirrorReaderFactory { public: IPersQueueMirrorReaderFactory() @@ -27,6 +29,7 @@ public: ActorSystemPtr->store(actorSystem, std::memory_order_relaxed); auto driverConfig = NYdb::TDriverConfig() + .SetMaxMessageSize(MaxMessageSize) .SetNetworkThreadsNum(settings.GetThreadsCount()); Driver = std::make_shared<NYdb::TDriver>(driverConfig); } |