Path	Lines of Code
build.cmd	11
sample/ProduceAndConsume/Program.cs	97
sample/PublishEfCore/Program.cs	80
sample/PublishEfCoreTransactional/Program.cs	86
sample/Subscribe/Program.cs	46
sample/SubscribeEfCore/Program.cs	121
sample/SubscribeEfCoreOffsets/Program.cs	63
src/Directory.Build.props	40
src/Epam.Kafka.HealthChecks/ClusterHealthCheck.cs	115
src/Epam.Kafka.HealthChecks/ClusterHealthCheckOptions.cs	10
src/Epam.Kafka.HealthChecks/KafkaHealthCheckExtensions.cs	26
src/Epam.Kafka.PubSub.EntityFramework6/CompatibilityExtensions.cs	26
src/Epam.Kafka.PubSub.EntityFrameworkCore/LogExtensions.cs	17
src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/Contracts/DbContextEntityPublicationHandler.cs	121
src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/Contracts/IKafkaPublicationEntity.cs	11
src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/Contracts/KafkaPublicationState.cs	14
src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/DbContextPublicationHandler.cs	91
src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/KafkaPublicationConcurrency.cs	12
src/Epam.Kafka.PubSub.EntityFrameworkCore/ServiceCollectionExtensions.cs	41
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextEntitySubscriptionHandler.cs	64
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextOffsetsStorage.cs	154
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextSubscriptionHandler.cs	96
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/State/IKafkaStateDbContext.cs	15
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/State/KafkaTopicState.cs	23
src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/State/KafkaTopicStateExtensions.cs	35
src/Epam.Kafka.PubSub/Common/HealthChecks/PubSubHealthCheck.cs	80
src/Epam.Kafka.PubSub/Common/HealthChecks/PubSubSummaryHealthCheck.cs	70
src/Epam.Kafka.PubSub/Common/Metrics/MetricsWithName.cs	24
src/Epam.Kafka.PubSub/Common/Metrics/PubSubHealthMetrics.cs	15
src/Epam.Kafka.PubSub/Common/Metrics/PubSubStatusMetrics.cs	11
src/Epam.Kafka.PubSub/Common/Options/PubSubOptions.cs	29
src/Epam.Kafka.PubSub/Common/Options/PubSubOptionsConfigure.cs	37
src/Epam.Kafka.PubSub/Common/Options/PubSubOptionsValidate.cs	59
src/Epam.Kafka.PubSub/Common/Pipeline/BatchResult.cs	8
src/Epam.Kafka.PubSub/Common/Pipeline/BatchStatus.cs	14
src/Epam.Kafka.PubSub/Common/Pipeline/PipelineMonitor.cs	76
src/Epam.Kafka.PubSub/Common/Pipeline/PipelineStatus.cs	12
src/Epam.Kafka.PubSub/Common/Pipeline/PubSubMonitor.cs	17
src/Epam.Kafka.PubSub/Common/Pipeline/StatusDetails.cs	23
src/Epam.Kafka.PubSub/Common/PubSubBackgroundService.cs	227
src/Epam.Kafka.PubSub/Common/PubSubBuilder.cs	62
src/Epam.Kafka.PubSub/Common/PubSubContext.cs	139
src/Epam.Kafka.PubSub/Common/TypeHelper.cs	27
src/Epam.Kafka.PubSub/KafkaBuilderExtensions.cs	151
src/Epam.Kafka.PubSub/Publication/DeliveryReport.cs	26
src/Epam.Kafka.PubSub/Publication/HealthChecks/PublicationHealthCheck.cs	61
src/Epam.Kafka.PubSub/Publication/IPublicationHandler.cs	10
src/Epam.Kafka.PubSub/Publication/Metrics/PublicationHealthMetrics.cs	21
src/Epam.Kafka.PubSub/Publication/Metrics/PublicationStatusMetrics.cs	13
src/Epam.Kafka.PubSub/Publication/Options/PublicationOptions.Internal.cs	46
src/Epam.Kafka.PubSub/Publication/Options/PublicationOptions.cs	16
src/Epam.Kafka.PubSub/Publication/Options/PublicationOptionsConfigure.cs	20
src/Epam.Kafka.PubSub/Publication/Options/PublicationOptionsValidate.cs	48
src/Epam.Kafka.PubSub/Publication/Pipeline/PublicationBatchResult.cs	11
src/Epam.Kafka.PubSub/Publication/Pipeline/PublicationMonitor.cs	23
src/Epam.Kafka.PubSub/Publication/PublicationBackgroundService.cs	167
src/Epam.Kafka.PubSub/Publication/PublicationBuilder.cs	70
src/Epam.Kafka.PubSub/Publication/PublicationHandler.cs	82
src/Epam.Kafka.PubSub/Publication/TopicMessage.cs	8
src/Epam.Kafka.PubSub/Publication/Topics/IPublicationTopicWrapper.cs	20
src/Epam.Kafka.PubSub/Publication/Topics/IPublicationTopicWrapperOptions.cs	15
src/Epam.Kafka.PubSub/Publication/Topics/PublicationSerializeKeyAndValueTopicWrapper.cs	114
src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapper.cs	242
src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapperExtensions.cs	49
src/Epam.Kafka.PubSub/Subscription/ExternalOffset.cs	7
src/Epam.Kafka.PubSub/Subscription/HealthChecks/SubscriptionHealthCheck.cs	70
src/Epam.Kafka.PubSub/Subscription/IExternalOffsetsStorage.cs	14
src/Epam.Kafka.PubSub/Subscription/ISubscriptionHandler.cs	7
src/Epam.Kafka.PubSub/Subscription/Metrics/SubscriptionHealthMetrics.cs	21
src/Epam.Kafka.PubSub/Subscription/Metrics/SubscriptionStatusMetrics.cs	13
src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptions.cs	22
src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptionsConfigure.cs	20
src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptionsExtensions.cs	84
src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptionsValidate.cs	69
src/Epam.Kafka.PubSub/Subscription/Pipeline/SubscriptionBatchResult.cs	12
src/Epam.Kafka.PubSub/Subscription/Pipeline/SubscriptionMonitor.cs	22
src/Epam.Kafka.PubSub/Subscription/Replication/ConvertHandler.cs	14
src/Epam.Kafka.PubSub/Subscription/Replication/IConvertHandler.cs	7
src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationBackgroundService.cs	46
src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationBuilder.cs	22
src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationHandler.cs	92
src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationOptions.Internal.cs	49
src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationOptions.cs	11
src/Epam.Kafka.PubSub/Subscription/State/BatchState.cs	50
src/Epam.Kafka.PubSub/Subscription/State/CombinedState.cs	50
src/Epam.Kafka.PubSub/Subscription/State/ExternalState.cs	65
src/Epam.Kafka.PubSub/Subscription/State/ExternalStateExtensions.cs	108
src/Epam.Kafka.PubSub/Subscription/State/InternalKafkaState.cs	40
src/Epam.Kafka.PubSub/Subscription/SubscriptionBackgroundService.cs	161
src/Epam.Kafka.PubSub/Subscription/SubscriptionBuilder.cs	93
src/Epam.Kafka.PubSub/Subscription/SubscriptionHandler.cs	120
src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	458
src/Epam.Kafka.PubSub/Utils/ActivityWrapper.cs	64
src/Epam.Kafka.PubSub/Utils/LogExtensions.cs	220
src/Epam.Kafka.PubSub/Utils/OffsetsExtensions.cs	37
src/Epam.Kafka.PubSub/Utils/RegexHelper.cs	15
src/Epam.Kafka.PubSub/Utils/RetryExtensions.cs	24
src/Epam.Kafka.PubSub/Utils/SerializationHelper.cs	47
src/Epam.Kafka/IKafkaFactory.cs	16
src/Epam.Kafka/Internals/ClientWrapper.cs	18
src/Epam.Kafka/Internals/CompatibilityExtensions.cs	57
src/Epam.Kafka/Internals/KafkaFactory.cs	285
src/Epam.Kafka/Internals/Observable/ObservableClient.cs	82
src/Epam.Kafka/Internals/Observable/ObservableConsumer.cs	160
src/Epam.Kafka/Internals/Observable/ObservableProducer.cs	97
src/Epam.Kafka/Internals/RegexHelper.cs	10
src/Epam.Kafka/Internals/SchemaRegistryConfigCustom.cs	10
src/Epam.Kafka/Internals/SharedClient.cs	32
src/Epam.Kafka/KafkaBuilder.Placeholders.cs	33
src/Epam.Kafka/KafkaBuilder.cs	76
src/Epam.Kafka/KafkaClientExtensions.cs	25
src/Epam.Kafka/KafkaConfigExtensions.cs	106
src/Epam.Kafka/LogExtensions.cs	75
src/Epam.Kafka/OAuthRefreshResult.cs	17
src/Epam.Kafka/Options/Configuration/ClusterOptionsConfigure.cs	33
src/Epam.Kafka/Options/Configuration/ConsumerOptionsConfigure.cs	15
src/Epam.Kafka/Options/Configuration/FactoryOptionsConfigure.cs	20
src/Epam.Kafka/Options/Configuration/OptionsFromConfiguration.cs	43
src/Epam.Kafka/Options/Configuration/ProducerOptionsConfigure.cs	15
src/Epam.Kafka/Options/KafkaClusterOptions.cs	45
src/Epam.Kafka/Options/KafkaConsumerOptions.cs	9
src/Epam.Kafka/Options/KafkaFactoryOptions.cs	10
src/Epam.Kafka/Options/KafkaProducerOptions.cs	9
src/Epam.Kafka/Options/Validation/ClusterValidation.cs	22
src/Epam.Kafka/Options/Validation/ConsumerValidation.cs	30
src/Epam.Kafka/Options/Validation/ProducerValidation.cs	23
src/Epam.Kafka/ProducerPartitioner.cs	24
src/Epam.Kafka/ServiceCollectionExtensions.cs	17
src/Epam.Kafka/TestMockCluster.cs	93