setup fix

Razz4780 · Oct 2, 2024 · 0195c9e · 0195c9e
1 parent 4d30e87
commit 0195c9e
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/mirrord/operator/src/setup.rs b/mirrord/operator/src/setup.rs
@@ -214,12 +214,10 @@ impl OperatorSetup for Operator {
         writer.write_all(b"---\n")?;
         MirrordPolicy::crd().to_writer(&mut writer)?;
 
-        if self.sqs_splitting || self.kafka_splitting {
+        if self.sqs_splitting {
             writer.write_all(b"---\n")?;
             MirrordWorkloadQueueRegistry::crd().to_writer(&mut writer)?;
-        }
 
-        if self.sqs_splitting {
             writer.write_all(b"---\n")?;
             MirrordSqsSession::crd().to_writer(&mut writer)?;
         }
@@ -230,6 +228,9 @@ impl OperatorSetup for Operator {
 
             writer.write_all(b"---\n")?;
             MirrordKafkaTemporaryTopic::crd().to_writer(&mut writer)?;
+
+            writer.write_all(b"---\n")?;
+            MirrordKafkaTopicsConsumer::crd().to_writer(&mut writer)?;
         }
 
         Ok(())