From eb410908e6a2dc496aa0e3772b2401749dd82b26 Mon Sep 17 00:00:00 2001
From: Ludovic DEHON <tchiot.ludo@gmail.com>
Date: Wed, 19 Jan 2022 17:04:17 +0100
Subject: [PATCH] fix(kafka-runner): missing server-type condition for
 scheduler in order to monitor their stream

---
 .../main/java/io/kestra/runner/kafka/KafkaStreamEndpoint.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index fcf06ba648..0f3bfd0dcc 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;