int addRawRecords(final Iterable<ConsumerRecord<byte[], byte[]>> rawRecords) {
        for (final ConsumerRecord<byte[], byte[]> rawRecord : rawRecords) {
            fifoQueue.addLast(rawRecord);
        }

        updateHead();

        return size();
    }
Add a batch of {@link ConsumerRecord} into the queue

@param rawRecords the raw records
@return the size of this queue
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java