Changed name of the operator feature for kafka splitting without copy

changelog.d/+kafka-splitting-copy-target.fixed.md

@@ -0,0 +1 @@
+Fixed logic for detecting whether the operator supports Kafka splitting without copying the target.

mirrord/operator/src/client.rs

@@ -564,7 +564,7 @@ impl OperatorApi<PreparedClientCert> {
                 && self
                     .operator()
                     .spec
-                    .require_feature(NewOperatorFeature::KafkaQueueSplittingNoCopy)
+                    .require_feature(NewOperatorFeature::KafkaQueueSplittingDirect)
                     .is_err());
         let (connect_url, session_id) = if do_copy_target {
             let mut copy_subtask = progress.subtask("copying target");

mirrord/operator/src/crd.rs

@@ -276,7 +276,7 @@ pub enum NewOperatorFeature {
     SqsQueueSplitting,
     KafkaQueueSplitting,
     LayerReconnect,
-    KafkaQueueSplittingNoCopy,
+    KafkaQueueSplittingDirect,
     /// This variant is what a client sees when the operator includes a feature the client is not
     /// yet aware of, because it was introduced in a version newer than the client's.
     #[schemars(skip)]
@@ -293,7 +293,7 @@ impl Display for NewOperatorFeature {
             NewOperatorFeature::SqsQueueSplitting => "SQS queue splitting",
             NewOperatorFeature::KafkaQueueSplitting => "Kafka queue splitting",
             NewOperatorFeature::LayerReconnect => "layer reconnect",
-            NewOperatorFeature::KafkaQueueSplittingNoCopy => {
+            NewOperatorFeature::KafkaQueueSplittingDirect => {
                 "Kafka queue splitting without copy target"
             }
             NewOperatorFeature::Unknown => "unknown feature",