public void add()

in src/main/java/com/epam/eco/commons/kafka/helpers/BiDirectionalTopicRecordFetcher.java [327:340]

• 12 lines of code
• 4 McCabe index (conditional complexity)

        public void add(ConsumerRecord<K, V> record) {
            if(isRecordExists(record)) {
                return;
            }
            if(isLimitReached()) {
                return;
            }

            updateScannedOffsets(record);

            if(passesFilter(record)) {
                records.add(record);
            }
        }