aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAleksandr Petrikhin <shmeleine@gmail.com>2022-06-30 17:59:10 +0300
committerAleksandr Petrikhin <shmeleine@gmail.com>2022-06-30 17:59:10 +0300
commitccf31faee2bc0c051b65ed5899060bd597b22c70 (patch)
tree2b27a8206f01ac3e121c8569284854cd88a8e1b9
parent1d8f8dfd93dc506a0fd6a696eda1cf149afdb1f8 (diff)
downloadydb-ccf31faee2bc0c051b65ed5899060bd597b22c70.tar.gz
LOGBROKER-7581 add default message size to actor_persqueue
ref:eec3f2edff3511a21c1c852ccb300a0126255aef
-rw-r--r--ydb/core/persqueue/actor_persqueue_client_iface.h3
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);
}