azure-functions-kafka-extension icon indicating copy to clipboard operation
azure-functions-kafka-extension copied to clipboard

Kafka extension for Azure Functions

Results 147 azure-functions-kafka-extension issues
Sort by recently updated
recently updated
newest added

Bumps [org.json:json](https://github.com/douglascrockford/JSON-java) from 20230227 to 20231013. Release notes Sourced from org.json:json's releases. 20231013 Pull Request Description #793 Reverted #761 #792 update the docs for release 20231013 #783 optLong vs getLong...

dependencies
java

Bumps [Azure.Identity](https://github.com/Azure/azure-sdk-for-net) from 1.6.0 to 1.10.2. Release notes Sourced from Azure.Identity's releases. Azure.Identity_1.10.2 1.10.2 (2023-10-10) Bugs Fixed Bug fixes for development time credentials. Azure.Identity_1.10.1 1.10.1 (2023-09-12) Bugs Fixed ManagedIdentityCredential will...

dependencies

Hello, I am trying to use the distributed tracing improvement in kafka trigger created in this PR : https://github.com/Azure/azure-functions-kafka-extension/pull/396 My testing setup is the following : Broker : kafka through...

investigate

Hello, I'm using KafkaOutput Trigger with Azure In-Process function. Surprisingly, it's not throwing any exception if I provide invalid brokername also. Just wondering, how would I get acknowledgement form or...

enhancement

For the consumer, the KafkaTriggerAttribute parameter SslKeyPassword is being resolved using the ResolveSecureSetting when building the consumer. So it support the % syntax to get the SslKeyPassword value from the...

enhancement

Hello everyone, The KafkaTargetScaler is using the obsolete [ScaleMonitorDescriptor](https://github.com/Azure/azure-webjobs-sdk/blob/8ef02d5a3a78056f9ec5a2bc9459b9600c0a0309/src/Microsoft.Azure.WebJobs.Host/Scale/ScaleMonitorDescriptor.cs#L19) constructor without the functionId parameter. ```csharp [Obsolete("This constructor is obsolete. Use the version that takes function id instead.")] public ScaleMonitorDescriptor(string id)...

I have an Avro schema that looks like this: ``` { "type": "array", "items": { "type": "record", "name": "myrecord", "fields": [ ... ] } } ``` If I try to...

Library upgrade

### Situation: We have a Kafka topic with 10 partitions. The main purpose of having 10 partitions is to process everything parallelly. We don't care about the order. Even we...

Needs: triage (functions)

While using Kafka triggered function with Avro schema, if the Avro schema has an array structure, then Kafka event message is not mapped with schema fields correctly and array field...