fix(kafka-runner): missing server-type condition for scheduler in ord…

…er to monitor their stream
kestra-io · Jan 19, 2022 · eb41090 · eb41090
1 parent 4a95629
commit eb41090
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/runner-kafka/src/main/java/io/kestra/runner/kafka/KafkaStreamEndpoint.java b/runner-kafka/src/main/java/io/kestra/runner/kafka/KafkaStreamEndpoint.java
@@ -19,7 +19,7 @@
 import java.util.stream.Collectors;
 
 @Endpoint(id = "kafkastreams", defaultSensitive = false)
-@Requires(property = "kestra.server-type", pattern = "(EXECUTOR|STANDALONE)")
+@Requires(property = "kestra.server-type", pattern = "(EXECUTOR|STANDALONE|SCHEDULER)")
 @KafkaQueueEnabled
 public class KafkaStreamEndpoint implements ApplicationEventListener<KafkaStreamEndpoint.Event>  {
     private Map<String, KafkaStreamService.Stream> streams;