We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7bd031c commit 2e71b97Copy full SHA for 2e71b97
ydb/core/persqueue/read_balancer.cpp
@@ -527,6 +527,8 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr
527
auto it = oldConsumers.find(consumer.GetName());
528
if (it != oldConsumers.end()) {
529
Consumers[consumer.GetName()] = std::move(it->second);
530
+ } else {
531
+ Consumers.insert(std::make_pair(consumer.GetName(), TConsumerInfo{}));
532
}
533
534
0 commit comments