diff --git a/extensions/Worker.Extensions.Kafka/release_notes.md b/extensions/Worker.Extensions.Kafka/release_notes.md index ca17cb549..1191642fc 100644 --- a/extensions/Worker.Extensions.Kafka/release_notes.md +++ b/extensions/Worker.Extensions.Kafka/release_notes.md @@ -4,6 +4,6 @@ - My change description (#PR/#issue) --> -### Microsoft.Azure.Functions.Worker.Extensions.Kafka +### Microsoft.Azure.Functions.Worker.Extensions.Kafka 3.10.0 -- \ No newline at end of file +- Added Schema Registry Attributes for Trigger and Output bindings \ No newline at end of file diff --git a/extensions/Worker.Extensions.Kafka/src/KafkaOutputAttribute.cs b/extensions/Worker.Extensions.Kafka/src/KafkaOutputAttribute.cs index da2954f3f..8ee86ecab 100644 --- a/extensions/Worker.Extensions.Kafka/src/KafkaOutputAttribute.cs +++ b/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. /// public int LingerMs { get; set; } = 5; + + /// + /// URL for the Avro Schema Registry + /// + public string SchemaRegistryUrl { get; set; } + + /// + /// Username for the Avro Schema Registry + /// + public string SchemaRegistryUsername { get; set; } + + /// + /// Password for the Avro Schema Registry + /// + public string SchemaRegistryPassword { get; set; } } } diff --git a/extensions/Worker.Extensions.Kafka/src/KafkaTriggerAttribute.cs b/extensions/Worker.Extensions.Kafka/src/KafkaTriggerAttribute.cs index c5ea4e79a..6708f7593 100644 --- a/extensions/Worker.Extensions.Kafka/src/KafkaTriggerAttribute.cs +++ b/extensions/Worker.Extensions.Kafka/src/KafkaTriggerAttribute.cs @@ -112,6 +112,21 @@ public KafkaTriggerAttribute(string brokerList, string topic) /// public long LagThreshold { get; set; } = 1000; + /// + /// URL for the Avro Schema Registry + /// + public string SchemaRegistryUrl { get; set; } + + /// + /// Username for the Avro Schema Registry + /// + public string SchemaRegistryUsername { get; set; } + + /// + /// Password for the Avro Schema Registry + /// + public string SchemaRegistryPassword { get; set; } + /// /// Gets or sets the configuration to enable batch processing of events. Default value is "false". /// diff --git a/extensions/Worker.Extensions.Kafka/src/Worker.Extensions.Kafka.csproj b/extensions/Worker.Extensions.Kafka/src/Worker.Extensions.Kafka.csproj index b5ca20c0f..bbf3f596c 100644 --- a/extensions/Worker.Extensions.Kafka/src/Worker.Extensions.Kafka.csproj +++ b/extensions/Worker.Extensions.Kafka/src/Worker.Extensions.Kafka.csproj @@ -5,7 +5,7 @@ Kafka extensions for .NET isolated functions - 3.9.0 + 3.10.0 false