diff options
| author | Nikolay Shestakov <tesseract@ydb.tech> | 2024-08-12 19:09:26 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-12 19:09:26 +0500 |
| commit | 976e2c703afb734c8996d901b3b87e862595234e (patch) | |
| tree | 8e277059e0df813982f872b74fe8b75ba9b3e5f3 | |
| parent | 9095bb1c65f7d877743c3647a2735acca664cf7d (diff) | |
| download | ydb-976e2c703afb734c8996d901b3b87e862595234e.tar.gz | |
fix suspended read session of a topic (#7647)
| -rw-r--r-- | ydb/core/persqueue/read_balancer__balancing.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/core/persqueue/read_balancer__balancing.cpp b/ydb/core/persqueue/read_balancer__balancing.cpp index 1eb83610748..5814973a34b 100644 --- a/ydb/core/persqueue/read_balancer__balancing.cpp +++ b/ydb/core/persqueue/read_balancer__balancing.cpp @@ -534,6 +534,7 @@ std::unique_ptr<TEvPersQueue::TEvReleasePartition> TPartitionFamily::MakeEvRelea r.SetPath(TopicPath()); r.SetGeneration(TabletGeneration()); r.SetClientId(Session->ClientId); + r.SetCount(1); r.SetGroup(partitionId + 1); ActorIdToProto(Session->Pipe, r.MutablePipeClient()); |