make max_workers a definable parameter

nuclio · Jan 3, 2024 · fee4259 · fee4259
1 parent 6a4c7a7
commit fee4259
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/nuclio/triggers.py b/nuclio/triggers.py
@@ -173,6 +173,7 @@ def __init__(
         partitions=None,
         consumer_group="kafka",
         initial_offset="earliest",
+        max_workers: int = 1,
         explicit_ack_mode=None,
         extra_attributes=None,
         session_timeout: str = "10s",
@@ -183,7 +184,7 @@ def __init__(
         super(KafkaTrigger, self).__init__(
             {
                 "kind": self.kind,
-                "maxWorkers": 1,
+                "maxWorkers": max_workers,
                 "attributes": {
                     "topics": topics,
                     "brokers": brokers,