Path	Lines of Code
CONTRIBUTING.md	10
README.md	360
SECURITY.md	24
samples/README.md	177
samples/WalletProcessing_KafkademoSample/ReadMe.md	127
samples/WalletProcessing_KafkademoSample/extensions.csproj	14
samples/WalletProcessing_KafkademoSample/host.json	3
samples/WalletProcessing_KafkademoSample/pom.xml	200
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/commons/Constant.java	4
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/converter/ResponseConverter.java	6
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/converter/WalletNotificationResponseConverter.java	45
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/Header.java	30
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/KafkaEntity.java	68
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/event/Notification.java	85
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/event/WalletTransaction.java	84
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/type/NotificationType.java	4
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/entity/wallet/WalletTransaction.java	626
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/execute/App.java	8
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/listeners/notification/NotificationListener.java	76
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/listeners/notification/email/NotificationEmailListener.java	24
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/listeners/notification/inapp/NotificationInAppListener.java	23
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/listeners/notification/sms/NotificationSMSListener.java	23
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/listeners/wallet/WalletTransactionListener.java	43
samples/WalletProcessing_KafkademoSample/src/main/java/com/microsoft/producer/WalletProducer.java	83
samples/WalletProcessing_KafkademoSample/src/main/resources/docker-compose.yaml	43
samples/WalletProcessing_KafkademoSample/src/main/resources/producer-config.properties	4
samples/container/kafka-function/README.md	39
samples/container/kafka-function/extensions.csproj	16
samples/container/kafka-function/host.json	3
samples/container/kafka-function/pom.xml	174
samples/container/kafka-function/src/main/java/com/contoso/kafka/TriggerFunction.java	25
samples/container/kafka-function/src/repo/com/microsoft/azure/functions/azure-functions-java-library-kafka/maven-metadata-local.xml	12
samples/dotnet-isolated/confluent/Confluent.csproj	24
samples/dotnet-isolated/confluent/KafkaOutput.cs	41
samples/dotnet-isolated/confluent/KafkaOutputMany.cs	40
samples/dotnet-isolated/confluent/KafkaOutputManyWithHeaders.cs	28
samples/dotnet-isolated/confluent/KafkaOutputWithHeaders.cs	30
samples/dotnet-isolated/confluent/KafkaTrigger.cs	24
samples/dotnet-isolated/confluent/KafkaTriggerMany.cs	28
samples/dotnet-isolated/confluent/KafkaTriggerManyWithHeaders.cs	35
samples/dotnet-isolated/confluent/KafkaTriggerWithHeaders.cs	32
samples/dotnet-isolated/confluent/Program.cs	17
samples/dotnet-isolated/confluent/host.json	16
samples/dotnet-isolated/eventhub/Eventhub.csproj	24
samples/dotnet-isolated/eventhub/KafkaOutput.cs	41
samples/dotnet-isolated/eventhub/KafkaOutputMany.cs	40
samples/dotnet-isolated/eventhub/KafkaOutputManyWithHeaders.cs	28
samples/dotnet-isolated/eventhub/KafkaOutputWithHeaders.cs	30
samples/dotnet-isolated/eventhub/KafkaTrigger.cs	24
samples/dotnet-isolated/eventhub/KafkaTriggerMany.cs	28
samples/dotnet-isolated/eventhub/KafkaTriggerManyWithHeaders.cs	35
samples/dotnet-isolated/eventhub/KafkaTriggerWithHeaders.cs	32
samples/dotnet-isolated/eventhub/Program.cs	17
samples/dotnet-isolated/eventhub/host.json	16
samples/dotnet/Confluent/Confluent.csproj	20
samples/dotnet/Confluent/KafkaOutput.cs	30
samples/dotnet/Confluent/KafkaOutputMany.cs	30
samples/dotnet/Confluent/KafkaOutputManyWithHeaders.cs	32
samples/dotnet/Confluent/KafkaOutputWithHeaders.cs	30
samples/dotnet/Confluent/KafkaTrigger.cs	22
samples/dotnet/Confluent/KafkaTriggerMany.cs	25
samples/dotnet/Confluent/KafkaTriggerManyWithHeaders.cs	32
samples/dotnet/Confluent/KafkaTriggerRetry.cs	39
samples/dotnet/Confluent/KafkaTriggerWithHeaders.cs	28
samples/dotnet/Confluent/host.json	11
samples/dotnet/ConsoleConsumer/ConsoleConsumer.csproj	17
samples/dotnet/ConsoleConsumer/MagicAvroDeserializer.cs	21
samples/dotnet/ConsoleConsumer/PageViewRegion.cs	37
samples/dotnet/ConsoleConsumer/PageViews.cs	34
samples/dotnet/ConsoleConsumer/Program.cs	319
samples/dotnet/ConsoleProducer/ConsoleProducer.csproj	18
samples/dotnet/ConsoleProducer/ITopicProducer.cs	9
samples/dotnet/ConsoleProducer/Program.cs	22
samples/dotnet/ConsoleProducer/ProtoBufSerializer.cs	10
samples/dotnet/ConsoleProducer/ProtobufTopicProducer.cs	105
samples/dotnet/ConsoleProducer/StringTopicProducer.cs	38
samples/dotnet/ConsoleProducer/User.cs	239
samples/dotnet/DistributedTracing/DistributedTracing.csproj	27
samples/dotnet/DistributedTracing/KafkaTriggerManyWithTracing.cs	41
samples/dotnet/DistributedTracing/KafkaTriggerWithTracing.cs	32
samples/dotnet/DistributedTracing/Readme.md	36
samples/dotnet/DistributedTracing/Startup.cs	46
samples/dotnet/DistributedTracing/host.json	15
samples/dotnet/EventHub/EventHub.csproj	20
samples/dotnet/EventHub/KafkaOutput.cs	30
samples/dotnet/EventHub/KafkaOutputMany.cs	30
samples/dotnet/EventHub/KafkaOutputManyWithHeaders.cs	32
samples/dotnet/EventHub/KafkaOutputWithHeaders.cs	30
samples/dotnet/EventHub/KafkaTrigger.cs	22
samples/dotnet/EventHub/KafkaTriggerMany.cs	25
samples/dotnet/EventHub/KafkaTriggerManyWithHeaders.cs	32
samples/dotnet/EventHub/KafkaTriggerRetry.cs	39
samples/dotnet/EventHub/KafkaTriggerWithHeaders.cs	28
samples/dotnet/EventHub/host.json	3
samples/dotnet/KafkaFunctionSample/AvroGenericTriggers.cs	50
samples/dotnet/KafkaFunctionSample/AvroGenericTriggersWithSchemaRegistry.cs	41
samples/dotnet/KafkaFunctionSample/AvroProduceStringTopicFunction.cs	65
samples/dotnet/KafkaFunctionSample/AvroProduceStringTopicFunctionWithSchemaRegistry.cs	69
samples/dotnet/KafkaFunctionSample/AvroSpecificTriggers.cs	22
samples/dotnet/KafkaFunctionSample/KafkaFunctionSample.csproj	22
samples/dotnet/KafkaFunctionSample/PageViewsFemale.cs	73
samples/dotnet/KafkaFunctionSample/ProduceStringTopicFunction.cs	96
samples/dotnet/KafkaFunctionSample/ProtoUser.cs	237
samples/dotnet/KafkaFunctionSample/ProtobufTriggers.cs	16
samples/dotnet/KafkaFunctionSample/RawTypeTriggers.cs	23
samples/dotnet/KafkaFunctionSample/SimpleKafkaTriggers.cs	45
samples/dotnet/KafkaFunctionSample/User.cs	58
samples/dotnet/KafkaFunctionSample/host.json	16
samples/dotnet/README.md	55
samples/dotnet/SampleHost/ExplicitTypeLocator.cs	19
samples/dotnet/SampleHost/Functions.cs	23
samples/dotnet/SampleHost/Program.cs	40
samples/dotnet/SampleHost/SampleHost.csproj	15
samples/java/README.md	158
samples/java/confluent/extensions.csproj	11
samples/java/confluent/host.json	3
samples/java/confluent/install_cacert.ps1	4
samples/java/confluent/pom.xml	181
samples/java/confluent/pom_linux.xml	196
samples/java/confluent/pom_windows.xml	196
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaOutputMany.java	27
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaOutputManyWithHeaders.java	34
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaOutputWithHeaders.java	30
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaTriggerMany.java	25
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaTriggerManyWithHeaders.java	35
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaTriggerRetry.java	26
samples/java/confluent/src/main/java/com/contoso/kafka/KafkaTriggerWithHeaders.java	29
samples/java/confluent/src/main/java/com/contoso/kafka/SampleKafkaOutput.java	27
samples/java/confluent/src/main/java/com/contoso/kafka/SampleKafkaTrigger.java	22
samples/java/confluent/src/main/java/com/contoso/kafka/avro/generic/KafkaTriggerAvroGeneric.java	46
samples/java/confluent/src/main/java/com/contoso/kafka/entity/KafkaEntity.java	17
samples/java/confluent/src/main/java/com/contoso/kafka/entity/KafkaHeaders.java	9
samples/java/confluent/src/main/java/com/contoso/kafka/entity/Payment.java	26
samples/java/confluent/src/repo/com/microsoft/azure/functions/azure-functions-java-library-kafka/maven-metadata-local.xml	12
samples/java/eventhub/extensions.csproj	11
samples/java/eventhub/host.json	3
samples/java/eventhub/pom.xml	181
samples/java/eventhub/pom_linux.xml	196
samples/java/eventhub/pom_windows.xml	196
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaOutputMany.java	27
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaOutputManyWithHeaders.java	32
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaOutputWithHeaders.java	28
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaTriggerMany.java	25
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaTriggerManyWithHeaders.java	33
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaTriggerRetry.java	46
samples/java/eventhub/src/main/java/com/contoso/kafka/KafkaTriggerWithHeaders.java	27
samples/java/eventhub/src/main/java/com/contoso/kafka/SampleKafkaOutput.java	27
samples/java/eventhub/src/main/java/com/contoso/kafka/SampleKafkaTrigger.java	22
samples/java/eventhub/src/main/java/com/contoso/kafka/avro/generic/KafkaTriggerAvroGeneric.java	64
samples/java/eventhub/src/main/java/com/contoso/kafka/entity/KafkaEntity.java	17
samples/java/eventhub/src/main/java/com/contoso/kafka/entity/KafkaHeaders.java	9
samples/java/eventhub/src/main/java/com/contoso/kafka/entity/Payment.java	26
samples/java/eventhub/src/repo/com/microsoft/azure/functions/azure-functions-java-library-kafka/maven-metadata-local.xml	12
samples/java/local/extensions.csproj	16
samples/java/local/host.json	3
samples/java/local/install_cacert.ps1	4
samples/java/local/pom.xml	176
samples/java/local/pom_linux.xml	196
samples/java/local/pom_windows.xml	196
samples/java/local/src/main/java/com/contoso/kafka/FunctionOutput.java	19
samples/java/local/src/main/java/com/contoso/kafka/TriggerFunction.java	12
samples/javascript-v4/README.md	75
samples/javascript-v4/extensions.csproj	16
samples/javascript-v4/host.json	3
samples/javascript-v4/package-lock.json	1642
samples/javascript-v4/package.json	18
samples/javascript-v4/proxies.json	4
samples/javascript-v4/src/functions/kafkaAvroGenericTrigger.js	25
samples/javascript-v4/src/functions/kafkaAvroGenericTriggerMany.js	28
samples/javascript-v4/src/functions/kafkaAvroGenericTriggerWithKeyAvro.js	31
samples/javascript-v4/src/functions/kafkaAvroGenericTriggerWithKeyAvroMany.js	33
samples/javascript-v4/src/functions/kafkaOutputManyWithHttpTrigger.js	33
samples/javascript-v4/src/functions/kafkaOutputManyWithHttpTriggerWithHeaders.js	46
samples/javascript-v4/src/functions/kafkaOutputManyWithTimerTrigger.js	16
samples/javascript-v4/src/functions/kafkaOutputManyWithTimerTriggerWithHeaders.js	18
samples/javascript-v4/src/functions/kafkaOutputWithHttpTrigger.js	45
samples/javascript-v4/src/functions/kafkaOutputWithHttpTriggerWithHeaders.js	50
samples/javascript-v4/src/functions/kafkaOutputWithTimerTrigger.js	16
samples/javascript-v4/src/functions/kafkaOutputWithTimerTriggerWithHeaders.js	17
samples/javascript-v4/src/functions/kafkaTrigger.js	31
samples/javascript-v4/src/functions/kafkaTriggerMany.js	34
samples/javascript-v4/src/functions/kafkaTriggerManyWithHeaders.js	38
samples/javascript-v4/src/functions/kafkaTriggerWithHeaders.js	35
samples/javascript-v4/src/functions/kafkaTriggerWithKeyDataType.js	26
samples/javascript-v4/src/functions/kafkaTriggerWithKeyValueDataType.js	28
samples/javascript-v4/src/functions/kafkaTriggerWithRetry.js	24
samples/javascript-v4/src/functions/kafkaTriggerWithValueDataType.js	25
samples/javascript-v4/src/functions/package.json	25
samples/javascript-v4/src/index.js	4
samples/javascript/KafkaAvroGenericTriggerMany/function.confluent.json	17
samples/javascript/KafkaAvroGenericTriggerMany/function.eventhub.json	17
samples/javascript/KafkaAvroGenericTriggerMany/index.js	6
samples/javascript/KafkaOutput/function.confluent.json	29
samples/javascript/KafkaOutput/function.eventhub.json	29
samples/javascript/KafkaOutput/index.js	8
samples/javascript/KafkaOutputMany/function.confluent.json	29
samples/javascript/KafkaOutputMany/function.eventhub.json	29
samples/javascript/KafkaOutputMany/index.js	7
samples/javascript/KafkaOutputManyWithHeaders/function.confluent.json	30
samples/javascript/KafkaOutputManyWithHeaders/function.eventhub.json	30
samples/javascript/KafkaOutputManyWithHeaders/index.js	10
samples/javascript/KafkaOutputWithHeader/function.confluent.json	30
samples/javascript/KafkaOutputWithHeader/function.eventhub.json	30
samples/javascript/KafkaOutputWithHeader/index.js	11
samples/javascript/KafkaTrigger/function.confluent.json	17
samples/javascript/KafkaTrigger/function.eventhub.json	17
samples/javascript/KafkaTrigger/index.js	3
samples/javascript/KafkaTriggerAvroGeneric/function.confluent.json	15
samples/javascript/KafkaTriggerAvroGeneric/function.eventhub.json	15
samples/javascript/KafkaTriggerAvroGeneric/index.js	3
samples/javascript/KafkaTriggerMany/function.confluent.json	18
samples/javascript/KafkaTriggerMany/function.eventhub.json	18
samples/javascript/KafkaTriggerMany/index.js	7
samples/javascript/KafkaTriggerManyWithHeaders/function.confluent.json	18
samples/javascript/KafkaTriggerManyWithHeaders/function.eventhub.json	18
samples/javascript/KafkaTriggerManyWithHeaders/index.js	12
samples/javascript/KafkaTriggerRetry/function.confluent.json	22
samples/javascript/KafkaTriggerRetry/function.eventhub.json	22
samples/javascript/KafkaTriggerRetry/index.js	4
samples/javascript/KafkaTriggerRetryExponential/function.confluent.json	23
samples/javascript/KafkaTriggerRetryExponential/function.eventhub.json	23
samples/javascript/KafkaTriggerRetryExponential/index.js	4
samples/javascript/KafkaTriggerWithHeaders/function.confluent.json	16
samples/javascript/KafkaTriggerWithHeaders/function.eventhub.json	17
samples/javascript/KafkaTriggerWithHeaders/index.js	4
samples/javascript/README.md	80
samples/javascript/extensions.csproj	16
samples/javascript/host.json	3
samples/javascript/package-lock.json	1117
samples/javascript/package.json	17
samples/javascript/proxies.json	4
samples/powershell/KafkaAvroGenericTriggerMany/function.confluent.json	17
samples/powershell/KafkaAvroGenericTriggerMany/function.eventhub.json	17
samples/powershell/KafkaAvroGenericTriggerMany/run.ps1	7
samples/powershell/KafkaOutput/function.confluent.json	29
samples/powershell/KafkaOutput/function.eventhub.json	29
samples/powershell/KafkaOutput/run.ps1	13
samples/powershell/KafkaOutputMany/function.confluent.json	29
samples/powershell/KafkaOutputMany/function.eventhub.json	29
samples/powershell/KafkaOutputMany/run.ps1	11
samples/powershell/KafkaOutputManyWithHeaders/function.confluent.json	29
samples/powershell/KafkaOutputManyWithHeaders/function.eventhub.json	29
samples/powershell/KafkaOutputManyWithHeaders/run.ps1	36
samples/powershell/KafkaOutputWithHeaders/function.confluent.json	29
samples/powershell/KafkaOutputWithHeaders/function.eventhub.json	29
samples/powershell/KafkaOutputWithHeaders/run.ps1	28
samples/powershell/KafkaTrigger/function.confluent.json	18
samples/powershell/KafkaTrigger/function.eventhub.json	18
samples/powershell/KafkaTrigger/run.ps1	3
samples/powershell/KafkaTriggerAvroGeneric/function.confluent.json	15
samples/powershell/KafkaTriggerAvroGeneric/function.eventhub.json	15
samples/powershell/KafkaTriggerAvroGeneric/run.ps1	3
samples/powershell/KafkaTriggerMany/function.confluent.json	19
samples/powershell/KafkaTriggerMany/function.eventhub.json	18
samples/powershell/KafkaTriggerMany/run.ps1	7
samples/powershell/KafkaTriggerManyWithHeaders/function.confluent.json	18
samples/powershell/KafkaTriggerManyWithHeaders/function.eventhub.json	18
samples/powershell/KafkaTriggerManyWithHeaders/run.ps1	12
samples/powershell/KafkaTriggerRetry/function.confluent.json	23
samples/powershell/KafkaTriggerRetry/function.eventhub.json	22
samples/powershell/KafkaTriggerRetry/run.ps1	4
samples/powershell/KafkaTriggerRetryExponential/function.confluent.json	24
samples/powershell/KafkaTriggerRetryExponential/function.eventhub.json	23
samples/powershell/KafkaTriggerRetryExponential/run.ps1	4
samples/powershell/KafkaTriggerWithHeaders/function.confluent.json	17
samples/powershell/KafkaTriggerWithHeaders/function.eventhub.json	17
samples/powershell/KafkaTriggerWithHeaders/run.ps1	11
samples/powershell/README.md	46
samples/powershell/extensions.csproj	16
samples/powershell/host.json	8
samples/powershell/producewithccloud.ps1	16
samples/python/KafkaAvroGenericTriggerMany/function.confluent.json	18
samples/python/KafkaAvroGenericTriggerMany/function.eventhub.json	18
samples/python/KafkaAvroGenericTriggerMany/main.py	6
samples/python/KafkaOutput/function.confluent.json	30
samples/python/KafkaOutput/function.eventhub.json	30
samples/python/KafkaOutput/main.py	6
samples/python/KafkaOutputMany/function.confluent.json	30
samples/python/KafkaOutputMany/function.eventhub.json	30
samples/python/KafkaOutputMany/main.py	7
samples/python/KafkaOutputManyWithHeaders/__init__.py	9
samples/python/KafkaOutputManyWithHeaders/function.confluent.json	30
samples/python/KafkaOutputManyWithHeaders/function.eventhub.json	30
samples/python/KafkaOutputWithHeaders/__init__.py	8
samples/python/KafkaOutputWithHeaders/function.confluent.json	30
samples/python/KafkaOutputWithHeaders/function.eventhub.json	30
samples/python/KafkaTrigger/function.confluent.json	16
samples/python/KafkaTrigger/function.eventhub.json	16
samples/python/KafkaTrigger/main.py	5
samples/python/KafkaTriggerAvroGeneric/function.confluent.json	16
samples/python/KafkaTriggerAvroGeneric/function.eventhub.json	16
samples/python/KafkaTriggerAvroGeneric/main.py	5
samples/python/KafkaTriggerMany/function.confluent.json	19
samples/python/KafkaTriggerMany/function.eventhub.json	19
samples/python/KafkaTriggerMany/main.py	6
samples/python/KafkaTriggerManyWithHeaders/__init__.py	13
samples/python/KafkaTriggerManyWithHeaders/function.confluent.json	19
samples/python/KafkaTriggerManyWithHeaders/function.eventhub.json	19
samples/python/KafkaTriggerRetry/function.confluent.json	21
samples/python/KafkaTriggerRetry/function.eventhub.json	21
samples/python/KafkaTriggerRetry/main.py	6
samples/python/KafkaTriggerRetryExponential/function.confluent.json	23
samples/python/KafkaTriggerRetryExponential/function.eventhub.json	23
samples/python/KafkaTriggerRetryExponential/main.py	6
samples/python/KafkaTriggerWithHeaders/__init__.py	9
samples/python/KafkaTriggerWithHeaders/function.confluent.json	18
samples/python/KafkaTriggerWithHeaders/function.eventhub.json	18
samples/python/README.md	88
samples/python/extensions.csproj	16
samples/python/host.json	3
samples/python/requirements.txt	1
samples/typescript-v4/README.md	18
samples/typescript-v4/extensions.csproj	16
samples/typescript-v4/host.json	3
samples/typescript-v4/package-lock.json	2129
samples/typescript-v4/package.json	25
samples/typescript-v4/src/functions/kafkaAvroGenericTrigger.ts	31
samples/typescript-v4/src/functions/kafkaAvroGenericTriggerMany.ts	35
samples/typescript-v4/src/functions/kafkaAvroGenericTriggerWithKeyAvro.ts	34
samples/typescript-v4/src/functions/kafkaAvroGenericTriggerWithKeyAvroMany.ts	36
samples/typescript-v4/src/functions/kafkaOutputManyWithHttpTrigger.ts	42
samples/typescript-v4/src/functions/kafkaOutputManyWithHttpTriggerWithHeaders.ts	55
samples/typescript-v4/src/functions/kafkaOutputManyWithTimerTrigger.ts	16
samples/typescript-v4/src/functions/kafkaOutputManyWithTimerTriggerWithHeaders.ts	18
samples/typescript-v4/src/functions/kafkaOutputWithHttpTrigger.ts	45
samples/typescript-v4/src/functions/kafkaOutputWithHttpTriggerWithHeaders.ts	50
samples/typescript-v4/src/functions/kafkaOutputWithTimerTrigger.ts	16
samples/typescript-v4/src/functions/kafkaOutputWithTimerTriggerWithHeaders.ts	17
samples/typescript-v4/src/functions/kafkaTrigger.ts	39
samples/typescript-v4/src/functions/kafkaTriggerMany.ts	49
samples/typescript-v4/src/functions/kafkaTriggerManyWithHeaders.ts	47
samples/typescript-v4/src/functions/kafkaTriggerWithHeaders.ts	44
samples/typescript-v4/src/functions/kafkaTriggerWithKeyDataType.ts	29
samples/typescript-v4/src/functions/kafkaTriggerWithKeyValueDataType.ts	31
samples/typescript-v4/src/functions/kafkaTriggerWithRetry.ts	28
samples/typescript-v4/src/functions/kafkaTriggerWithValueDataType.ts	28
samples/typescript-v4/src/index.ts	4
samples/typescript-v4/tsconfig.json	10
samples/typescript/KafkaAvroGenericTriggerMany/function.confluent.json	18
samples/typescript/KafkaAvroGenericTriggerMany/function.eventhub.json	18
samples/typescript/KafkaAvroGenericTriggerMany/index.ts	7
samples/typescript/KafkaOutput/function.confluent.json	30
samples/typescript/KafkaOutput/function.eventhub.json	30
samples/typescript/KafkaOutput/index.ts	10
samples/typescript/KafkaOutputMany/function.confluent.json	30
samples/typescript/KafkaOutputMany/function.eventhub.json	30
samples/typescript/KafkaOutputMany/index.ts	9
samples/typescript/KafkaOutputManyWithHeaders/function.confluent.json	30
samples/typescript/KafkaOutputManyWithHeaders/function.eventhub.json	30
samples/typescript/KafkaOutputManyWithHeaders/index.ts	10
samples/typescript/KafkaOutputWithHeaders/function.confluent.json	30
samples/typescript/KafkaOutputWithHeaders/function.eventhub.json	30
samples/typescript/KafkaOutputWithHeaders/index.ts	10
samples/typescript/KafkaTrigger/function.confluent.json	18
samples/typescript/KafkaTrigger/function.eventhub.json	18
samples/typescript/KafkaTrigger/index.ts	39
samples/typescript/KafkaTriggerAvroGeneric/function.confluent.json	17
samples/typescript/KafkaTriggerAvroGeneric/function.eventhub.json	16
samples/typescript/KafkaTriggerAvroGeneric/index.ts	5
samples/typescript/KafkaTriggerMany/function.confluent.json	19
samples/typescript/KafkaTriggerMany/function.eventhub.json	19
samples/typescript/KafkaTriggerMany/index.ts	30
samples/typescript/KafkaTriggerManyWithHeaders/function.confluent.json	19
samples/typescript/KafkaTriggerManyWithHeaders/function.eventhub.json	19
samples/typescript/KafkaTriggerManyWithHeaders/index.ts	39
samples/typescript/KafkaTriggerRetry/function.confluent.json	23
samples/typescript/KafkaTriggerRetry/function.eventhub.json	23
samples/typescript/KafkaTriggerRetry/index.ts	40
samples/typescript/KafkaTriggerRetryExponential/function.confluent.json	23
samples/typescript/KafkaTriggerRetryExponential/function.eventhub.json	24
samples/typescript/KafkaTriggerRetryExponential/index.ts	40
samples/typescript/KafkaTriggerWithHeaders/function.confluent.json	18
samples/typescript/KafkaTriggerWithHeaders/function.eventhub.json	18
samples/typescript/KafkaTriggerWithHeaders/index.ts	37
samples/typescript/README.md	18
samples/typescript/extensions.csproj	16
samples/typescript/host.json	3
samples/typescript/package-lock.json	1216
samples/typescript/package.json	25
samples/typescript/tsconfig.json	10
stylecop.json	18
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/appsettings.tests.json	3
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/host.json	8
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/host.json	8
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/MultiHttpTriggerKafkaOutput/function.json	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/MultiKafkaTriggerQueueOutput/function.json	26
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/SingleHttpTriggerKafkaOutput/function.json	31
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/SingleKafkaTriggerQueueOutput/function.json	24
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/host.json	16
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/requirements.txt	3
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/MultiHttpTriggerKafkaOutput/function.json	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/MultiKafkaTriggerQueueOutput/function.json	26
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/SingleHttpTriggerKafkaOutput/function.json	31
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/SingleKafkaTriggerQueueOutput/function.json	24
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/host.json	16
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/requirements.txt	3
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/LocalSetup.md	28
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/java8/host.json	3
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/host.json	3
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/kafka_output/function.json	22
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/kafka_trigger/function.json	20
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/local.settings.json	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/requirements.txt	1
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/xunit.runner.json	5
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/xunit.runner.json	4