From 7f03fb2ba11d0939b2da9996520a810db11825db Mon Sep 17 00:00:00 2001
From: Pavan Kumar <gopidesupavan@gmail.com>
Date: Fri, 27 Sep 2024 19:27:41 +0100
Subject: [PATCH] remove callable functions parameter from kafka operator
 template_fields

---
 airflow/providers/apache/kafka/operators/consume.py | 1 -
 airflow/providers/apache/kafka/operators/produce.py | 1 -
 2 files changed, 2 deletions(-)

diff --git a/airflow/providers/apache/kafka/operators/consume.py b/airflow/providers/apache/kafka/operators/consume.py
index 91d2f4f052da..377b58a46df5 100644
--- a/airflow/providers/apache/kafka/operators/consume.py
+++ b/airflow/providers/apache/kafka/operators/consume.py
@@ -68,7 +68,6 @@ class ConsumeFromTopicOperator(BaseOperator):
     ui_color = BLUE
     template_fields = (
         "topics",
-        "apply_function",
         "apply_function_args",
         "apply_function_kwargs",
         "kafka_config_id",
diff --git a/airflow/providers/apache/kafka/operators/produce.py b/airflow/providers/apache/kafka/operators/produce.py
index 04090811b9ec..e0623128a1f7 100644
--- a/airflow/providers/apache/kafka/operators/produce.py
+++ b/airflow/providers/apache/kafka/operators/produce.py
@@ -67,7 +67,6 @@ class ProduceToTopicOperator(BaseOperator):
 
     template_fields = (
         "topic",
-        "producer_function",
         "producer_function_args",
         "producer_function_kwargs",
         "kafka_config_id",