add templating to consumer fields (#7)

astronomer · Aug 3, 2022 · 7914f6a · 7914f6a
1 parent 287683e
commit 7914f6a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow_provider_kafka/operators/consume_from_topic.py b/airflow_provider_kafka/operators/consume_from_topic.py
@@ -46,7 +46,7 @@ class ConsumeFromTopicOperator(BaseOperator):
 
     BLUE = "#ffefeb"
     ui_color = BLUE
-
+    template_fields = ('topics', 'apply_function', 'apply_function_args', 'apply_function_kwargs')
     def __init__(
         self,
         topics: Sequence[str],