DBZ-8464 Using correct label in API Service discriminator

debezium · Nov 27, 2024 · 1b9ee63 · 1b9ee63
1 parent 3f996bf
commit 1b9ee63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...main/java/io/debezium/operator/core/dependent/discriminators/ApiServiceDiscriminator.java b/...main/java/io/debezium/operator/core/dependent/discriminators/ApiServiceDiscriminator.java
@@ -11,7 +11,7 @@
 
 import io.debezium.operator.api.model.CommonLabels;
 import io.debezium.operator.api.model.DebeziumServer;
-import io.debezium.operator.core.dependent.JmxServiceDependent;
+import io.debezium.operator.core.dependent.ApiServiceDependent;
 import io.fabric8.kubernetes.api.model.Service;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.ResourceDiscriminator;
@@ -21,7 +21,7 @@ public class ApiServiceDiscriminator implements ResourceDiscriminator<Service, D
     @Override
     public Optional<Service> distinguish(Class<Service> resource, DebeziumServer primary, Context<DebeziumServer> context) {
         return context.getSecondaryResourcesAsStream(Service.class)
-                .filter(s -> hasLabel(s, CommonLabels.KEY_DBZ_CLASSIFIER, JmxServiceDependent.JMX_CLASSIFIER))
+                .filter(s -> hasLabel(s, CommonLabels.KEY_DBZ_CLASSIFIER, ApiServiceDependent.CLASSIFIER))
                 .findFirst();
     }
 }