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 b48f081 commit 02176a8Copy full SHA for 02176a8
ydb/core/persqueue/read_balancer.cpp
@@ -372,6 +372,8 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr
372
auto it = oldConsumers.find(consumer.GetName());
373
if (it != oldConsumers.end()) {
374
Consumers[consumer.GetName()] = std::move(it->second);
375
+ } else {
376
+ Consumers.insert(std::make_pair(consumer.GetName(), TConsumerInfo{}));
377
}
378
379
0 commit comments