Skip to content

Commit 5c7eda0

Browse files
committed
revert brainfuck
1 parent 8f3a06a commit 5c7eda0

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

  • rust/operator-binary/src/crd

rust/operator-binary/src/crd/mod.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,8 +290,9 @@ impl v1alpha1::KafkaCluster {
290290
}
291291
};
292292

293-
// only return descriptors for selected role
294-
if let Some(current_role) = requested_kafka_role {
293+
// If no specific role is requested, or the current role matches the requested one, add pod descriptors
294+
if requested_kafka_role.is_none() || &current_role == requested_kafka_role.unwrap()
295+
{
295296
for replica in 0..replicas {
296297
pod_descriptors.push(KafkaPodDescriptor {
297298
namespace: namespace.clone(),

0 commit comments

Comments
 (0)