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
index fcf06ba648a..0f3bfd0dcc0 100644
--- 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;