diff options
Diffstat (limited to 'ydb/core/persqueue/read_balancer.cpp')
| -rw-r--r-- | ydb/core/persqueue/read_balancer.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/persqueue/read_balancer.cpp b/ydb/core/persqueue/read_balancer.cpp index 4eb9c7206d..f69f08b412 100644 --- a/ydb/core/persqueue/read_balancer.cpp +++ b/ydb/core/persqueue/read_balancer.cpp @@ -303,7 +303,7 @@ void TPersQueueReadBalancer::HandleOnInit(TEvPersQueue::TEvUpdateBalancerConfig: void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvGetPartitionIdForWrite::TPtr &ev, const TActorContext &ctx) { NextPartitionIdForWrite = (NextPartitionIdForWrite + 1) % TotalGroups; //TODO: change here when there will be more than 1 partition in partition_group. - THolder<TEvPersQueue::TEvGetPartitionIdForWriteResponse> response = MakeHolder<TEvPersQueue::TEvGetPartitionIdForWriteResponse>(); + THolder<TEvPersQueue::TEvGetPartitionIdForWriteResponse> response = MakeHolder<TEvPersQueue::TEvGetPartitionIdForWriteResponse>(); response->Record.SetPartitionId(NextPartitionIdForWrite); ctx.Send(ev->Sender, response.Release()); if (NextPartitionIdForWrite == StartPartitionIdForWrite) { // randomize next cycle |