fix: add upstream in store when start in read mode

infinyon · Mar 28, 2024 · 9f54137 · 9f54137
1 parent cc16a75
commit 9f54137
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/crates/fluvio-sc/src/start.rs b/crates/fluvio-sc/src/start.rs
@@ -200,6 +200,11 @@ async fn create_memory_client(path: PathBuf) -> Result<Arc<MemoryClient>> {
         client.create_item(value.as_input()).await?;
     }
 
+    for value in &config.upstream_clusters {
+        info!(name = &value.metadata.name, "read upstream cluster");
+        client.create_item(value.as_input()).await?;
+    }
+
     Ok(Arc::new(client))
 }