diff options
| author | timestep <timestep@yandex-team.ru> | 2022-02-10 16:49:17 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:17 +0300 |
| commit | 38b4bd28ca420294f532ac7ca6b2770d60e3dfd0 (patch) | |
| tree | 7570cb7cabf97af7ecb6ffe485e8037d516daa29 /ydb/core/persqueue/read_balancer.cpp | |
| parent | a0ffafe83b7d6229709a32fa942c71d672ac989c (diff) | |
| download | ydb-38b4bd28ca420294f532ac7ca6b2770d60e3dfd0.tar.gz | |
Restoring authorship annotation for <timestep@yandex-team.ru>. Commit 1 of 2.
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 |