azure-functions-kafka-extension
azure-functions-kafka-extension copied to clipboard
Azure
Kafka extension for Azure Functions
Conlfuent.kafka and librdkafka supports authentication certificate in pem string format using "ssl.certificate.pem" and "ssl.key.pem" attributes. You do not have to maintain certificate as file within application or certificate store with...
Avro doesn't seem to be supported as a first class citizen in the Java bindings (I end up with UnsupportedOperationException: Interface can't be instantiated! Interface name: org.apache.avro.generic.GenericRecord when I try...
Hi, I've followed the instructions for linux and they wrok perfectly. -adding LD_LIBRARY_PATH...- Now we have another box running osx and the library are not found: defining LD_LIBRARY_PATH and osx...
Hi guys, Do you know if is there any way to enable Azure Application Insights tracing propagation when using Kafka input and output bindings? I tried to find something in...
Hello, For now in order to use a custom CA certificate, it needs to be referenced using SslCaLocation in the KafkaTrigger, and the certificate needs to be deployed along with...
Hello, I have a function app with 2 different functions, each of which with a KafkaTrigger listening to a dedicated topic, so : - **functionA** listens to **topic-a** - **functionB**...
As manual commit option is not available, What can be done for the messages which are failed while processing? Retry policy is available but after retrying also if it's get...
Hello, as far as I can see there isn't any option to manually mark a message as processed correctly (Commit/CommitAsync?) and when a client (C# webjob) throws an error, the...
I'm working on consuming a Kafka feed with messages in the Avro format. I built a sample console application using Confulent Kafka library and can successfully connect to the broker,...
There is not much about setting up a secured connection to Kafka based on certs and passwords (called SSL, I believe). Could you help me out here a little? I...