Merge 369ba1e into 932db4f

FloatingCrowbar · web-flow · commit 6a795ebc5cd7 · 2024-12-13T16:52:55.000+03:00
diff --git a/ydb/core/persqueue/read_balancer.cpp b/ydb/core/persqueue/read_balancer.cpp
@@ -373,6 +373,8 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr
         auto it = oldConsumers.find(consumer.GetName());
         if (it != oldConsumers.end()) {
             Consumers[consumer.GetName()] = std::move(it->second);
+        } else {
+            Consumers.insert(std::make_pair(consumer.GetName(), TConsumerInfo{}));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -373,6 +373,8 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr`
`373`	`373`	`auto it = oldConsumers.find(consumer.GetName());`
`374`	`374`	`if (it != oldConsumers.end()) {`
`375`	`375`	`Consumers[consumer.GetName()] = std::move(it->second);`
	`376`	`+ } else {`
	`377`	`+ Consumers.insert(std::make_pair(consumer.GetName(), TConsumerInfo{}));`
`376`	`378`	`}`
`377`	`379`	`}`
`378`	`380`