Path	Lines of Code
src/test/java/com/epam/eco/commons/kafka/AdminClientUtilsTest.java	26
src/test/java/com/epam/eco/commons/kafka/BrokerConfigDefTest.java	29
src/test/java/com/epam/eco/commons/kafka/KafkaUtilsTest.java	62
src/test/java/com/epam/eco/commons/kafka/OffsetRangeTest.java	196
src/test/java/com/epam/eco/commons/kafka/StatsLoggerTest.java	43
src/test/java/com/epam/eco/commons/kafka/TopicConfigDefTest.java	29
src/test/java/com/epam/eco/commons/kafka/config/AbstractConfigDefTest.java	30
src/test/java/com/epam/eco/commons/kafka/config/AdminClientConfigBuilderTest.java	75
src/test/java/com/epam/eco/commons/kafka/config/ConsumerConfigBuilderTest.java	109
src/test/java/com/epam/eco/commons/kafka/config/ProducerConfigBuilderTest.java	99
src/test/java/com/epam/eco/commons/kafka/config/TestConsumerInterceptor1.java	21
src/test/java/com/epam/eco/commons/kafka/config/TestConsumerInterceptor2.java	21
src/test/java/com/epam/eco/commons/kafka/config/TestProducerInterceptor1.java	20
src/test/java/com/epam/eco/commons/kafka/config/TestProducerInterceptor2.java	20
src/test/java/com/epam/eco/commons/kafka/consumer/advanced/AdvancedConsumerIT.java	238
src/test/java/com/epam/eco/commons/kafka/consumer/advanced/AdvancedConsumerTest.java	97
src/test/java/com/epam/eco/commons/kafka/consumer/advanced/RecordBatchIteratorTest.java	50
src/test/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapConsumerIT.java	30
src/test/java/com/epam/eco/commons/kafka/helpers/BiDirectionalTopicRecordFetcherTest.java	172
src/test/java/com/epam/eco/commons/kafka/helpers/CachedTopicRecordFetcherTest.java	84
src/test/java/com/epam/eco/commons/kafka/helpers/ConfluentUtils.java	28
src/test/java/com/epam/eco/commons/kafka/helpers/ConsumerMock.java	127
src/test/java/com/epam/eco/commons/kafka/helpers/PartitionRecordFetchResultTest.java	112
src/test/java/com/epam/eco/commons/kafka/helpers/RecordFetchResultTest.java	123
src/test/java/com/epam/eco/commons/kafka/helpers/TopicRecordFetcherTest.java	85
src/test/java/com/epam/eco/commons/kafka/serde/GenericJsonDeserializerTest.java	34
src/test/java/com/epam/eco/commons/kafka/serde/HexStringDeserializerTest.java	17
src/test/java/com/epam/eco/commons/kafka/serde/JsonSerdeTest.java	78
src/test/java/com/epam/eco/commons/kafka/serde/JsonStringDeserializerTest.java	25
src/test/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordJsonDeserializerTest.java	212
src/test/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordJsonSerializerTest.java	166
src/test/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordSerdeTest.java	50
src/test/java/com/epam/eco/commons/kafka/serde/jackson/HeaderSerdeTest.java	22
src/test/java/com/epam/eco/commons/kafka/serde/jackson/HeadersSerdeTest.java	27
src/test/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalJsonDeserializerTest.java	35
src/test/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalJsonSerializerTest.java	34
src/test/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalSerdeTest.java	21
src/test/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderJsonDeserializerTest.java	38
src/test/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderJsonSerializerTest.java	35
src/test/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeadersJsonDeserializerTest.java	52
src/test/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeadersJsonSerializerTest.java	34
src/test/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionJsonDeserializerTest.java	36
src/test/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionJsonSerializerTest.java	34
src/test/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionKeyDeserializerTest.java	46
src/test/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionSerdeTest.java	38
src/test/java/com/epam/eco/commons/kafka/util/TestObjectMapperSingleton.java	15