Tsuyoshi Ushio

Thank you for the suggestion, Let me investigate it.

Probably, most of the case, we don't need to set auto commit to false. We have Retry policy https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-error-pages?tabs=csharp#retry-policies-preview. Combined with this retry policy, what happens is, 1. Kafka Extension...

Through the discussion, what you want is, the feature that is not commit if the exception thrown, right? It is possible, however, currently we are designing the exception handling as...

Hi @gliljas Thank you for your contribution. The code looks good. Could you update the documentation on our Readme?

Hi @gliljas and @fbeltrao What is the current status? No rush, however I'm curious. I'm preparing to release 3.3.0. :) I'll release it on this weekend. If this feature coming,...

Thank you for the request. I'd like to consider to add sample.

Hi @amotl It is not isolated sample, however, I wrote E2E testing for the python function as well. The Python functions part includes E2E testing with output bindings. https://github.com/Azure/azure-functions-kafka-extension/pull/199 https://github.com/Azure/azure-functions-kafka-extension/tree/tsushi/e2elanguage/test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/kafka_output

Hi @fbeltrao Could you explain more detail of this issue?

Hi @snehayadavv This is a python sample, however might similar to your case. https://github.com/Azure/azure-functions-kafka-extension/blob/dev/samples/python/KafkaTriggerMany/function.json_ For the root certificate configuration, you can refer Java sample. Java write is as annotation, however,...

Could you specify a specific cacert file to the sslCaLocation? It looks directory. For example, "sslCaLocation" : "/YOUR_PATH/confluent_cloud_cacert.pem"