azure-functions-kafka-extension

azure-functions-kafka-extension copied to clipboard

need control in setting the commit offset value (i.e manual commit) with Kafka extension instead of auto commit

2

At high load, we see duplicate events consumption issue when we use Function app with Kafka trigger. Hence, we are looking for a feature where we could set the offset...

thilakbe

Hi Team We keep getting the below errors in our Functions that use Kafka Triggers: `2023-06-28T20:33:15Z [Verbose] Taking metrics samples for 1 monitor(s). 2023-06-28T20:33:15Z [Verbose] Scale metrics sample for monitor...

Gerthum

Key deserializer was not specified - ISpecificRecord Key

1

Hi everyone! My team is migrating one on-premises application to Azure, and we decided to use AzureFunctions with KafkaTrigger. To have the necessary objects in place, we are using the...

danielbojczuk

Allowing event key that implements ISpecificRecord

3

This PR adds the necessary code to allow an event key that implements the ISpecificRecord.

danielbojczuk

adding parameter to enable transaction commit https://www.confluent.io/blog/transactions-apache-kafka/

BrunoLucasCloud

Serialization error for timestamp

1

Hello, i have azure function which is triggered by kafka message. It's basic body looks like: ` public class GeneratePdfFunction { [Function("GeneratePdfFunction")] public static void Run([KafkaTrigger("localhost:19092", "functions_requests", ConsumerGroup = "3")]...

bartoszgrzeda

KafkaOutput Trigger throws an error if null value passed

3

I'm using kafka out trigger to push message but there is some business scenario which identify whether to pass message or not. But if we pass null to message it...

Alpesh1984909090

The libkafka setting of `isolation.level` is not exposed or bound during the bootstrapping process. Control of this parameter is required when consuming from a topic that has been produced utilizing...

copjon

Hi, I'm dealing with an error when I'm using KafkaTrigger to listing a topic and record into a MongoDB, it work as expected running in a Windows machine but when...

PTLozano

RegisterSchemaAsync Runtime error

3

Getting this on both local mode and Azure funapp deployment ( EP1 app plan , dotnet runtime) ``` System.Private.CoreLib: Method 'RegisterSchemaAsync' in type 'Microsoft.Azure.WebJobs.Extensions.Kafka.LocalSchemaRegistry' from assembly 'Microsoft.Azure.WebJobs.Extensions.Kafka, Version=3.8.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35'...

dserdyuk