Path	Lines of Code
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/Constants.cs	16
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/EndToEndTestExtensions.cs	32
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/KafkaEndToEndTestFixture.cs	75
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/KafkaEndToEndTests.cs	839
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/KafkaOutputFunctions.cs	249
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/KafkaOutputFunctionsForProduceAndConsume.cs	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/KafkaTriggerForProduceAndConsume.cs	21
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests.csproj	40
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/Models/MyAvroRecord.cs	44
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/TestLoggerProvider.cs	14
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/TriggerFunctions.cs	292
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/kafka-singlenode-compose.yaml	33
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/start-kafka-test-environment.sh	4
test/Microsoft.Azure.WebJobs.Extensions.Kafka.EndToEndTests/stop-kafka-test-environment.sh	2
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/AppType.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/BaseE2E.cs	72
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/BrokerType.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/HttpCommand.cs	77
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/IExecutableCommand.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/QueueCommand.cs	50
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/Shell/DockerKillCommand.cs	17
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/Shell/DockerRunCommand.cs	41
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/Shell/ShellCommand.cs	19
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/Shell/ShellCommandFactory.cs	19
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Command/Shell/ShellCommandType.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Constants.cs	144
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Entity/HttpRequestEntity.cs	40
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Entity/KafkaEntity.cs	5
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Executor/CommandExecutor/HttpCommandExecutor.cs	11
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Executor/CommandExecutor/ShellCommandExecutor.cs	11
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Executor/IExecutor.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Executor/ProcessExecutor.cs	39
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Invoke/E2ETestInvoker.cs	15
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Invoke/InvokeType.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Invoke/Strategy/IInvokeRequestStrategy.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Invoke/Strategy/InvokeHttpRequestStrategy.cs	20
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Invoke/Strategy/InvokeKafkaRequestStrategy.cs	14
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/KafkaE2EFixture.cs	29
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Language.cs	12
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/ProcessLifecycleManager.cs	29
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueManager/AzureStorageQueueManager.cs	69
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueManager/EventHubQueueManager.cs	115
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueManager/IQueueManager.cs	11
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueManager/KafkaQueueManager.cs	32
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueOperation.cs	11
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueRequest.cs	24
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueResponse.cs	19
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Queue/QueueType.cs	8
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/TestLogger.cs	17
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/TestSuitInitializer.cs	65
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/TestSuiteCleaner.cs	42
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Common/Utils.cs	69
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Fixtures/JavaConfluentE2EFixture.cs	9
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Fixtures/JavaEventhubE2EFixture.cs	9
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Fixtures/PythonConfluentE2EFixture.cs	9
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Fixtures/PythonEventhubE2EFixture.cs	9
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/extensions.csproj	15
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/pom.xml	82
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/src/main/java/com/function/MultiHttpTriggerKafkaOutput.java	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/src/main/java/com/function/MultiKafkaTriggerQueueOutput.java	32
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/src/main/java/com/function/SingleHttpTriggerKafkaOutput.java	24
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/Confluent/src/main/java/com/function/SingleKafkaTriggerQueueOutput.java	25
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/extensions.csproj	15
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/pom.xml	82
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/src/main/java/com/function/MultiHttpTriggerKafkaOutput.java	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/src/main/java/com/function/MultiKafkaTriggerQueueOutput.java	32
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/src/main/java/com/function/SingleHttpTriggerKafkaOutput.java	24
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/java/EventHub/src/main/java/com/function/SingleKafkaTriggerQueueOutput.java	25
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/MultiHttpTriggerKafkaOutput/__init__.py	18
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/MultiKafkaTriggerQueueOutput/__init__.py	12
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/SingleHttpTriggerKafkaOutput/__init__.py	20
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/SingleKafkaTriggerQueueOutput/__init__.py	6
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/extensions.csproj	12
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/Confluent/start.sh	1
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/MultiHttpTriggerKafkaOutput/__init__.py	18
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/MultiKafkaTriggerQueueOutput/__init__.py	12
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/SingleHttpTriggerKafkaOutput/__init__.py	20
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/SingleKafkaTriggerQueueOutput/__init__.py	6
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/extensions.csproj	13
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/FunctionApps/python/EventHub/start.sh	1
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests.csproj	45
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/Facts/IgnoreOnDisableConfluentTestsFlagFact.cs	19
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/Facts/IgnoreOnDisableEventHubsTestsFlagFact.cs	20
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/JavaConfluentAppTest.cs	31
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/JavaEventhubAppTest.cs	32
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/PythonConfluentAppTest.cs	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/Tests/PythonEventhubAppTest.cs	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/java8/extensions.csproj	18
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/java8/pom.xml	196
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/java8/src/main/java/com/contoso/kafka/KafkaTriggerTests.java	27
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/extensions.csproj	16
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/kafka_output/main.py	5
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/kafka_trigger/main.py	8
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/python38/start.sh	1
test/Microsoft.Azure.WebJobs.Extensions.Kafka.LangEndToEndTests/server/start-kafka-test-environment.sh	4
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/AzureFunctionsFileHelperTest.cs	60
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/DiagnosticTest.cs	172
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/Helpers/AzureEnvironment.cs	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/Helpers/KafkaListenerForTest.cs	46
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/Helpers/TestConsumerBuilder.cs	14
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaAttributeTests.cs	83
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaEventDataHeaderTest.cs	14
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaEventDataHeadersTest.cs	110
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaEventDataTest.cs	97
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaListenerTest.cs	527
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaMessageBuilderTest.cs	83
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaMetricsProviderForTest.cs	30
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaMetricsProviderTest.cs	117
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaProducerFactoryTest.cs	383
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaScalerProviderTest.cs	71
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaTargetScalerForTest.cs	25
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaTargetScalerTest.cs	127
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaTopicScalerTest.cs	236
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaTriggerAttributeBindingProviderTest.cs	537
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/KafkaTriggerBindingStrategyTest.cs	115
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests.csproj	37
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/MyAvroRecord.cs	44
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/output/CollectorValueProviderTest.cs	23
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/output/KafkaProducerAsyncCollectorTest.cs	104
test/Microsoft.Azure.WebJobs.Extensions.Kafka.UnitTests/output/KafkaProducerEntityTest.cs	46
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/CultureFixture.cs	33
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/ExplicitTypeLocator.cs	20
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/Microsoft.WebJobs.Extensions.Tests.Common.csproj	35
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/Properties/AssemblyInfo.cs	7
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestConfigurationBuilderExtensions.cs	15
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestExceptionHandler.cs	24
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestHelpers.cs	48
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestLogger.cs	79
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestLoggerProvider.cs	14
test/Microsoft.Azure.WebJobs.Extensions.Tests.Common/TestNameResolver.cs	32