protected int consumeAvailableRecords(Consumer<SourceRecord> recordConsumer){
  List<SourceRecord> records=new LinkedList<>();
  consumedLines.drainTo(records);
  if (recordConsumer != null) {
    records.forEach(recordConsumer);
  }
  return records.size();
}

protected int consumeAvailableRecords ( Consumer < SourceRecord > recordConsumer ) { List < SourceRecord > records = new LinkedList < > ( ) ; consumedLines . drainTo ( records ) ; if ( recordConsumer != null ) { records . forEach ( recordConsumer ) ; } return records . size ( ) ; }
try to consume all of the messages that have already been returned by the connector .
