Skip to content

Commit 9ccadbf

Browse files
Bugfix for alter consumers in pqrb (#12613) (#12714)
1 parent 499ab3a commit 9ccadbf

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ydb/core/persqueue/read_balancer.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -527,6 +527,8 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr
527527
auto it = oldConsumers.find(consumer.GetName());
528528
if (it != oldConsumers.end()) {
529529
Consumers[consumer.GetName()] = std::move(it->second);
530+
} else {
531+
Consumers.insert(std::make_pair(consumer.GetName(), TConsumerInfo{}));
530532
}
531533
}
532534

0 commit comments

Comments
 (0)