Skip to content

Commit cea6a08

Browse files
authored
Fixed a backward compatibility issue for PQv0 (#18716)
2 parents 9481b8f + b171923 commit cea6a08

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

ydb/core/persqueue/read_balancer__balancing.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -552,6 +552,7 @@ std::unique_ptr<TEvPersQueue::TEvReleasePartition> TPartitionFamily::MakeEvRelea
552552
auto& r = res->Record;
553553

554554
r.SetSession(Session->SessionName);
555+
r.SetCount(1);
555556
r.SetTopic(Topic());
556557
r.SetPath(TopicPath());
557558
r.SetGeneration(TabletGeneration());

ydb/core/protos/pqconfig.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -653,7 +653,7 @@ message TReleasePartition {
653653
optional uint64 Generation = 2;
654654
optional string Session = 3;
655655
optional string ClientId = 4;
656-
reserved 5; // optional uint32 Count = 5;
656+
optional uint32 Count = 5;
657657
optional NActorsProto.TActorId PipeClient = 6;
658658
optional uint32 Group = 7;
659659
optional string Path = 8;

0 commit comments

Comments
 (0)