azurefunctions_sink_test

Documentation for the Azure Functions Sink Connector is here

generate_data.sh script creates input topic for sink connector and fill it with 100+ events Among these 100+ events, few will make the azure function generate a 400 (keyed by 'key_400') and few a 500 error (keyed by 'key_500')

init.js is the body of the azure function I used

azure-functions-sink.json is the basic config file for the Azure function Sink Connector

azure-functions-bis-sink.json is the config file for the Azure function Sink Connector using batch and parallel requests

If you use Confluent CLI, just run

  1. confluent local load azure-functions -- -d path/to/azure-functions-sink.json
  2. confluent local load azure-functions-bis -- -d path/to/azure-functions-bis-sink.json