Merge branch 'main' into restore-format

Author: Konstantin Morozov

ydb/core/blobstorage/nodewarden/distconf.cpp

@@ -173,7 +173,7 @@ namespace NKikimr::NStorage {
                 break;
         }
 
-        if (NodeListObtained && StorageConfigLoaded && change) {
+        if (change && NodeListObtained && StorageConfigLoaded) {
             UpdateBound(SelfNode.NodeId(), SelfNode, *StorageConfig, nullptr);
             IssueNextBindRequest();
             processPendingEvents();
@@ -202,8 +202,11 @@ namespace NKikimr::NStorage {
     }
 
     void TNodeWarden::StartDistributedConfigKeeper() {
-        return;
-        DistributedConfigKeeperId = Register(new TDistributedConfigKeeper(Cfg, StorageConfig));
+        auto *appData = AppData();
+        if (!appData->DynamicNameserviceConfig || SelfId().NodeId() <= appData->DynamicNameserviceConfig->MaxStaticNodeId) {
+            // start distributed configuration machinery only on static nodes
+            DistributedConfigKeeperId = Register(new TDistributedConfigKeeper(Cfg, StorageConfig));
+        }
     }
 
     void TNodeWarden::ForwardToDistributedConfigKeeper(STATEFN_SIG) {

ydb/core/blobstorage/nodewarden/distconf_binding.cpp

@@ -58,7 +58,7 @@ namespace NKikimr::NStorage {
         // issue updates
         NodeIds = std::move(nodeIds);
         BindQueue.Update(NodeIds);
-        if (StorageConfig) {
+        if (NodeListObtained && StorageConfigLoaded) {
             IssueNextBindRequest();
         }
     }

ydb/core/kafka_proxy/actors/actors.h

@@ -163,5 +163,6 @@ NActors::IActor* CreateKafkaFindCoordinatorActor(const TContext::TPtr context, c
 NActors::IActor* CreateKafkaOffsetCommitActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetCommitRequestData>& message);
 NActors::IActor* CreateKafkaOffsetFetchActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetFetchRequestData>& message);
 NActors::IActor* CreateKafkaCreateTopicsActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TCreateTopicsRequestData>& message);
+NActors::IActor* CreateKafkaCreatePartitionsActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TCreatePartitionsRequestData>& message);
 
 } // namespace NKafka