Adding Schema Regsistry attributes for kafka trigger and ouput

extensions/Worker.Extensions.Kafka/release_notes.md

@@ -4,6 +4,6 @@
 - My change description (#PR/#issue)
 -->
 
-### Microsoft.Azure.Functions.Worker.Extensions.Kafka <version>
+### Microsoft.Azure.Functions.Worker.Extensions.Kafka 3.10.0
 
-- <entry>
+- Added Schema Registry Attributes for Trigger and Output bindings

extensions/Worker.Extensions.Kafka/src/KafkaOutputAttribute.cs

@@ -128,5 +128,20 @@ public KafkaOutputAttribute(string brokerList, string topic)
         /// being sent to cluster. Larger value allows more batching results in high throughput.
         /// </summary>
         public int LingerMs { get; set; } = 5;
+
+        /// <summary>
+        /// URL for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryUrl { get; set; }
+
+        /// <summary>
+        /// Username for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryUsername { get; set; }
+
+        /// <summary>
+        /// Password for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryPassword { get; set; }
     }
 }

extensions/Worker.Extensions.Kafka/src/KafkaTriggerAttribute.cs

@@ -112,6 +112,21 @@ public KafkaTriggerAttribute(string brokerList, string topic)
         /// </summary>
         public long LagThreshold { get; set; } = 1000;
 
+        /// <summary>
+        /// URL for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryUrl { get; set; }
+
+        /// <summary>
+        /// Username for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryUsername { get; set; }
+
+        /// <summary>
+        /// Password for the Avro Schema Registry
+        /// </summary>
+        public string SchemaRegistryPassword { get; set; }
+
         /// <summary>
         /// Gets or sets the configuration to enable batch processing of events. Default value is "false".
         /// </summary>

extensions/Worker.Extensions.Kafka/src/Worker.Extensions.Kafka.csproj

@@ -5,7 +5,7 @@
     <Description>Kafka extensions for .NET isolated functions</Description>
 
     <!--Version information-->
-    <VersionPrefix>3.9.0</VersionPrefix>
+    <VersionPrefix>3.10.0</VersionPrefix>
 
     <!--Temporarily opting out of documentation. Pending documentation-->
     <GenerateDocumentationFile>false</GenerateDocumentationFile>