Browse Source

fix suspended read session of a topic (#7647)

Nikolay Shestakov 7 months ago
parent
commit
976e2c703a
1 changed files with 1 additions and 0 deletions
  1. 1 0
      ydb/core/persqueue/read_balancer__balancing.cpp

+ 1 - 0
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());