azure-functions-kafka-extension
azure-functions-kafka-extension copied to clipboard
Azure
Kafka extension for Azure Functions
Should support external Avro schema registry. Currently only fix Avro schemas are supported.
Hi, First, my last issue was about having problems adding the kafka extension this one was addressed by down grading the dotnet runtime from 5 to 3 which is ok....
I am using azure function kafka extension in my project in javascript. I am creating a consumer that would listen to already existing kafka topic(secure cluster). To access this topic...
Add support to message header properties in Kafka events. **Trigger** - [ ] Add headers to KafkaEventData - [ ] Expose properties in KafkaEventData and binding properties **Output** - [...
Allows injecting custom scaling logic. Now, in fairness, the factory could have been an IScaleMonitorFactory. Use case: Custom handling of scaling, based on metrics, such as ensuring (at least trying)...
Just a POC. Kafka and the Confluent client has support for listening to multiple topics with only one consumer. It would be quite useful to use that functionality with KafkaTrigger,...
It's useful e.g in a scenario where multiple functions are in the same function app, and there's something (like in our case, a retry handler) that should be able to...
# Issue If we want to use `KafkaEventData.Key`, it will requires to define your function parameter with the type that has two generic types with `KafkaEventData`. ```csharp public async Task...
The problem here is that Azure network loadbalancing components silently drop idle network connections after 4 minutes. I upgrade to Confluent 1.5.2. to solve this issue, however, it still remains....
Update the samples to the version 3.1.0 ## What I did * Upgrade sample from 3.0.0 to 3.1.0 * Remove cacert.pem since It no longer needed * Remove cacert.pem from...