Path	Lines of Code
spotbugs-exclude.xml	178
src/main/java/com/epam/eco/commons/kafka/Acks.java	18
src/main/java/com/epam/eco/commons/kafka/AdminClientUtils.java	1002
src/main/java/com/epam/eco/commons/kafka/CleanupPolicy.java	20
src/main/java/com/epam/eco/commons/kafka/KafkaUtils.java	246
src/main/java/com/epam/eco/commons/kafka/OffsetRange.java	99
src/main/java/com/epam/eco/commons/kafka/OffsetReset.java	8
src/main/java/com/epam/eco/commons/kafka/ScalaConversions.java	64
src/main/java/com/epam/eco/commons/kafka/SslProtocol.java	23
src/main/java/com/epam/eco/commons/kafka/StatsLogger.java	130
src/main/java/com/epam/eco/commons/kafka/TopicPartitionComparator.java	17
src/main/java/com/epam/eco/commons/kafka/TransactionState.java	37
src/main/java/com/epam/eco/commons/kafka/config/AbstractClientConfigBuilder.java	203
src/main/java/com/epam/eco/commons/kafka/config/AbstractConfigBuilder.java	53
src/main/java/com/epam/eco/commons/kafka/config/AbstractConfigDef.java	63
src/main/java/com/epam/eco/commons/kafka/config/AbstractSecurityConfigBuilder.java	261
src/main/java/com/epam/eco/commons/kafka/config/AdminClientConfigBuilder.java	13
src/main/java/com/epam/eco/commons/kafka/config/BrokerConfigDef.java	21
src/main/java/com/epam/eco/commons/kafka/config/ConfigKeyComparator.java	13
src/main/java/com/epam/eco/commons/kafka/config/ConsumerConfigBuilder.java	231
src/main/java/com/epam/eco/commons/kafka/config/ProducerConfigBuilder.java	161
src/main/java/com/epam/eco/commons/kafka/config/TopicConfigBuilder.java	123
src/main/java/com/epam/eco/commons/kafka/config/TopicConfigDef.java	20
src/main/java/com/epam/eco/commons/kafka/consumer/advanced/AdvancedConsumer.java	343
src/main/java/com/epam/eco/commons/kafka/consumer/advanced/DefaultRecordBatchIterator.java	68
src/main/java/com/epam/eco/commons/kafka/consumer/advanced/InternalRecordBatchIterator.java	6
src/main/java/com/epam/eco/commons/kafka/consumer/advanced/RecordBatchIterator.java	11
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BeginningOffsetInitializer.java	13
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapConsumer.java	277
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapConsumerExecutor.java	93
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapConsumerThread.java	69
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapException.java	9
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ConsumerGroupOffsetThresholdProvider.java	116
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/CountingRecordsCollector.java	18
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/EndOffsetInitializer.java	13
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/EndOffsetThresholdProvider.java	24
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/OffsetInitializer.java	7
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/OffsetThresholdProvider.java	11
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/RecordCollector.java	6
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/TimestampOffsetInitializer.java	108
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ToListDecodingRecordCollector.java	55
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ToListFullRecordCollector.java	7
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ToListRecordCollector.java	38
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ToMapDecodingRecordCollector.java	50
src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ToMapRecordCollector.java	31
src/main/java/com/epam/eco/commons/kafka/helpers/BiDirectionalTopicRecordFetcher.java	277
src/main/java/com/epam/eco/commons/kafka/helpers/CachedTopicRecordFetcher.java	269
src/main/java/com/epam/eco/commons/kafka/helpers/FilterClausePredicate.java	5
src/main/java/com/epam/eco/commons/kafka/helpers/GroupOffsetResetter.java	153
src/main/java/com/epam/eco/commons/kafka/helpers/PartitionRecordFetchResult.java	104
src/main/java/com/epam/eco/commons/kafka/helpers/RecordBiDirectionalFetcher.java	20
src/main/java/com/epam/eco/commons/kafka/helpers/RecordCounter.java	70
src/main/java/com/epam/eco/commons/kafka/helpers/RecordFetchResult.java	143
src/main/java/com/epam/eco/commons/kafka/helpers/RecordFetcher.java	85
src/main/java/com/epam/eco/commons/kafka/helpers/TopicOffsetFetcher.java	75
src/main/java/com/epam/eco/commons/kafka/helpers/TopicOffsetForTimeFetcher.java	87
src/main/java/com/epam/eco/commons/kafka/helpers/TopicOffsetRangeFetcher.java	98
src/main/java/com/epam/eco/commons/kafka/helpers/TopicRecordFetcher.java	485
src/main/java/com/epam/eco/commons/kafka/serde/GenericJsonDeserializer.java	19
src/main/java/com/epam/eco/commons/kafka/serde/HexStringDeserializer.java	16
src/main/java/com/epam/eco/commons/kafka/serde/JsonDeserializer.java	52
src/main/java/com/epam/eco/commons/kafka/serde/JsonSerializer.java	24
src/main/java/com/epam/eco/commons/kafka/serde/JsonStringDeserializer.java	45
src/main/java/com/epam/eco/commons/kafka/serde/KeyValueDecoder.java	5
src/main/java/com/epam/eco/commons/kafka/serde/ObjectMapperSingleton.java	13
src/main/java/com/epam/eco/commons/kafka/serde/SimpleTransactionMetadataDecoder.java	19
src/main/java/com/epam/eco/commons/kafka/serde/TransactionMetadataDecoder.java	20
src/main/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordFields.java	18
src/main/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordJsonDeserializer.java	184
src/main/java/com/epam/eco/commons/kafka/serde/jackson/ConsumerRecordJsonSerializer.java	98
src/main/java/com/epam/eco/commons/kafka/serde/jackson/JsonDeserializerUtils.java	73
src/main/java/com/epam/eco/commons/kafka/serde/jackson/KafkaModule.java	28
src/main/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalFields.java	7
src/main/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalJsonDeserializer.java	37
src/main/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalJsonSerializer.java	19
src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderFields.java	7
src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderJsonDeserializer.java	39
src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderJsonSerializer.java	19
src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeadersJsonDeserializer.java	42
src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeadersJsonSerializer.java	21
src/main/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionFields.java	7
src/main/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionJsonDeserializer.java	46
src/main/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionJsonSerializer.java	22
src/main/java/com/epam/eco/commons/kafka/serde/jackson/TopicPartitionKeyDeserializer.java	11