Path	Lines of Code
azure-pipelines.yaml	160
build/common.props	19
script/create_package.ps1	6
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/AzureFunctionsFileHelper.cs	142
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/BrokerAuthenticationMode.cs	15
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/BrokerProtocol.cs	12
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaExtensionConfigProvider.cs	61
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaMessageKeyType.cs	12
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaOptions.cs	90
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaWebJobsBuilderExtensions.cs	46
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/OAuthBearerMethod.cs	12
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Diagnostics/ActivityProvider.cs	52
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Diagnostics/ActivityTags.cs	18
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Diagnostics/BatchEventActivityProvider.cs	63
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Diagnostics/KafkaEventInstrumentation.cs	21
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Diagnostics/SingleEventActivityProvider.cs	38
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Extensions/ConfigurationExtensions.cs	20
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Extensions/KafkaMessageKeyTypeExtensions.cs	24
src/Microsoft.Azure.WebJobs.Extensions.Kafka/IKafkaEventData.cs	15
src/Microsoft.Azure.WebJobs.Extensions.Kafka/IKafkaEventDataHeader.cs	9
src/Microsoft.Azure.WebJobs.Extensions.Kafka/IKafkaEventDataHeaders.cs	16
src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaEventData.cs	100
src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaEventDataHeader.cs	15
src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaEventDataHeaders.cs	84
src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaWebJobsStartup.cs	14
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs	350
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTargetScaler.cs	123
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTopicScaler.cs	156
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaMetricsProvider.cs	151
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaObjectTargetScaler.cs	16
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaObjectTopicScaler.cs	13
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaScalerProvider.cs	165
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Microsoft.Azure.WebJobs.Extensions.Kafka.targets	8
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/AsyncCollectorArgumentBindingProvider.cs	66
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/ByteArrayArgumentBindingProvider.cs	36
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/ByteArrayToKafkaEventDataConverter.cs	14
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/CollectorValueProvider.cs	40
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/CompositeKafkaProducerBindingProvider.cs	27
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/Converter/IConverter.cs	11
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/IKafkaProducer.cs	13
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/IKafkaProducerBindingProvider.cs	10
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/IKafkaProducerFactory.cs	9
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaAttribute.cs	54
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaAttributeBinding.cs	93
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaAttributeBindingProvider.cs	55
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaEventDataArgumentBinding.cs	60
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaEventDataArgumentBindingProvider.cs	26
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaMessageBuilder.cs	50
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducer.cs	159
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs	132
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerEntity.cs	44
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerFactory.cs	163
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/NonNullArrayConverterValueBinder.cs	48
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/NonNullConverterValueBinder.cs	48
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/SerializableTypeArgumentBindingProvider.cs	95
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/StringArgumentBindingProvider.cs	79
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/StringToKafkaEventDataConverter.cs	14
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Properties/AssemblyInfo.cs	4
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/LocalSchemaRegistry.cs	112
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/ProtobufDeserializer.cs	16
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/ProtobufSerializer.cs	11
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/SerializationHelper.cs	90
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/AsyncCommitStrategy.cs	28
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/FunctionExecutorBase.cs	145
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/ICommitStrategy.cs	11
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaEventDataConvertManager.cs	137
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaListenerConfiguration.cs	51
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttribute.cs	56
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttributeBindingProvider.cs	165
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerBindingStrategy.cs	125
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerBindingWrapper.cs	36
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerInput.cs	47
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerMetrics.cs	16
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/MultipleItemFunctionExecutor.cs	100
src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/SingleItemFunctionExecutor.cs	88
update-version.ps1	54