setup fix

metalbear-co · Sep 30, 2024 · 0341fca · 0341fca
1 parent 28f5abd
commit 0341fca
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(())