azure-functions-kafka-extension

azure-functions-kafka-extension copied to clipboard

https://docs.microsoft.com/en-us/azure/azure-functions/functions-triggers-bindings There is no mention about the kafka trigger. We need to update to add it.

TsuyoshiUshio

Nice to have deadlettering

1

Include an optional setting where you can specify a deadletter Kafka stream in your config somewhere and it will deadletter to that for you after retries have been exceeded.

ryancrawcour

Nice to have: create topics if it does not exist

1

It would be nice to create topic on the fly if it does not exist. That would require topic information such as name, partition count, replication factor, etc. When defining...

fbeltrao

Currently uses the "old" method of writing bindings, which some earlier bindings (SB/Storage/etc) all still use. There is a newer way to do this that doesn't require nearly as much...

ryancrawcour

Configurable cursor position to start processing

5

As a developer, I would like the ability to optional set the starting cursor position when processing the Kafka event stream, so that I can start from a specific position...

mcollier

We have a sample of alpine Docker images in here. https://github.com/Azure/azure-functions-kafka-extension/blob/dev/samples/java/Dockerfile In this, PR, I include v3 host docker sample. https://github.com/Azure/azure-functions-kafka-extension/pull/140 We need to decide if we should support Alpine...

TsuyoshiUshio

Python Kafka Output Trigger - Nested collections issue

2

Kafka output trigger for Python gives a nested collection error from host. This is not related to Python code.

priyaananthasankar

Should review serialisation

2

Currently we support built-in serialisation for avro and protobuf. Avro relies on Confluent.Kafka. Protobuf relies on google.protobuf. Having serialisation built-in has the following advantages: - Performance when using a language...

fbeltrao

This is not high priority however, source link might help customer to debug this trigger. https://github.com/dotnet/sourcelink

TsuyoshiUshio

Bumps [Azure.Storage.Queues](https://github.com/Azure/azure-sdk-for-net) from 12.9.0 to 12.11.0. Commits dd17f33 July Release Prep - Confidential Ledger (#29675) b62fd9f [AzureMonitorExporter] Split Integration.Tests project (#29703) ad4d05e fix test construction (#29700) 4586797 Fix null errors...

dependabot[bot]