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 f3a1ae1 commit c3a263eCopy full SHA for c3a263e
1 file changed
rust/operator-binary/src/controller/validate.rs
@@ -254,10 +254,7 @@ where
254
255
/// Injects the operator-managed `KAFKA_CLUSTER_ID` into the merged env overrides,
256
/// but only when the user has not already set it via `envOverrides` (user value
257
-/// wins, preserving product-config's old precedence).
258
-///
259
-/// `KAFKA_CLUSTER_ID` injection moved here from the now-removed
260
-/// `crd::role::*::Configuration::compute_env`.
+/// wins).
261
fn inject_cluster_id(env_overrides: EnvVarSet, cluster_id: Option<&str>) -> Result<EnvVarSet> {
262
let Some(cluster_id) = cluster_id else {
263
return Ok(env_overrides);
0 commit comments