diff --git a/ydb/core/persqueue/read_balancer__balancing.cpp b/ydb/core/persqueue/read_balancer__balancing.cpp index 4130dd83b749..da26dd8aaa6a 100644 --- a/ydb/core/persqueue/read_balancer__balancing.cpp +++ b/ydb/core/persqueue/read_balancer__balancing.cpp @@ -533,6 +533,7 @@ std::unique_ptr TPartitionFamily::MakeEvRelea r.SetPath(TopicPath()); r.SetGeneration(TabletGeneration()); r.SetClientId(Session->ClientId); + r.SetCount(1); r.SetGroup(partitionId + 1); ActorIdToProto(Session->Pipe, r.MutablePipeClient());