diff --git a/Kudu.Core/Functions/KedaFunctionTriggerProvider.cs b/Kudu.Core/Functions/KedaFunctionTriggerProvider.cs
index 2cfaba6e..8de2147c 100644
--- a/Kudu.Core/Functions/KedaFunctionTriggerProvider.cs
+++ b/Kudu.Core/Functions/KedaFunctionTriggerProvider.cs
@@ -365,7 +365,7 @@ internal static IDictionary<string, string> PopulateMetadataDictionary(JToken t,
                     break;
 
                 case TriggerTypes.Kafka:
-                    metadata["bootstrapServers"] = metadata["brokerList"];
+                    metadata["bootstrapServersFromEnv"] = metadata["brokerList"];
                     metadata.Remove("brokerList");
                     metadata.Remove("protocol");
                     metadata.Remove("authenticationMode");