Info
| Version: | 3.9.0 |
| Author(s): | Microsoft |
| Last Update: | Friday, July 28, 2023 |
| .NET Fiddle: | Online Example |
| Project Url: | http://go.microsoft.com/fwlink/?LinkID=320972 |
| NuGet Url: | https://www.nuget.org/packages/Microsoft.Azure.WebJobs.Extensions.Kafka |
Install
Install-Package Microsoft.Azure.WebJobs.Extensions.Kafka
dotnet add package Microsoft.Azure.WebJobs.Extensions.Kafka
paket add Microsoft.Azure.WebJobs.Extensions.Kafka
Microsoft.Azure.WebJobs.Extensions.Kafka Download (Unzip the "nupkg" after downloading)
Dependencies
- Confluent.Kafka(>= 1.6.04)
- Confluent.SchemaRegistry(>= 1.6.04)
- Confluent.SchemaRegistry.Serdes.Avro(>= 1.6.04)
- Confluent.SchemaRegistry.Serdes.Protobuf(>= 1.6.04)
- Microsoft.Azure.WebJobs(>= 3.0.14)
- System.Threading.Channels(>= 4.5.0)
It is also fully supported when using Azure Functions on Kubernetes where scaling will be handed by KEDA - scaling based on Kafka queue length. It is currently not supported on the Consumption plan (there will be no scale from zero) - this is something the Azure Functions team is still working on.