[Merged by Bors] - Fix node selector

CHANGELOG.md

@@ -6,12 +6,14 @@ All notable changes to this project will be documented in this file.
 
 ### Changed
 
+- Fixed the RoleGroup `selector`. It was not used before. ([#530])
 - Updated stackable image versions ([#513]).
-- operator-rs: 0.26.0 -> 0.27.1 ([#519]).
+- operator-rs: 0.26.0 -> 0.30.1 ([#519], [#530]).
 - Don't run init container as root and avoid chmod and chowning ([#524]).
 - [BREAKING] Use Product image selection instead of version. `spec.version` has been replaced by `spec.image` ([#482]).
 - [BREAKING]: Removed tools image for init and get-svc container and replaced with Kafka product image. This means the latest stackable version has to be used in the product image selection ([#527])
 
+[#530]: https://github.com/stackabletech/kafka-operator/pull/530
 [#482]: https://github.com/stackabletech/kafka-operator/pull/482
 [#513]: https://github.com/stackabletech/kafka-operator/pull/513
 [#519]: https://github.com/stackabletech/kafka-operator/pull/519

rust/crd/Cargo.toml

@@ -9,7 +9,7 @@ version = "0.9.0-nightly"
 publish = false
 
 [dependencies]
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.27.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.30.1" }
 
 semver = "1.0.14"
 serde = { version = "1.0.147", features = ["derive"] }

rust/operator-binary/Cargo.toml

@@ -12,15 +12,15 @@ publish = false
 [dependencies]
 stackable-kafka-crd = { path = "../crd" }
 stackable-kafka-operator = { path = "../operator" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.27.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.30.1" }
 
 clap = "4.0.26"
 tokio = { version = "1.23.0", features = ["macros", "rt-multi-thread"] }
 tracing = "0.1.37"
 
 [build-dependencies]
 built = { version = "0.5.1", features = ["chrono", "git2"] }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.27.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.30.1" }
 stackable-kafka-crd = { path = "../crd" }
 
 [[bin]]

rust/operator/Cargo.toml

@@ -10,7 +10,7 @@ publish = false
 
 [dependencies]
 stackable-kafka-crd = { path = "../crd" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.27.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.30.1" }
 
 futures = "0.3.25"
 serde = { version = "1.0.147", features = ["derive"] }

rust/operator/src/kafka_controller.rs

@@ -845,6 +845,7 @@ fn build_broker_rolegroup_statefulset(
         .add_init_container(container_get_svc)
         .add_container(cb_kafka.build())
         .add_container(container_kcat_prober)
+        .node_selector_opt(rolegroup.selector.clone())
         .add_volume(Volume {
             name: "config".to_string(),
             config_map: Some(ConfigMapVolumeSource {