protected SourceRecord consumeRecord() throws InterruptedException {
  return consumedLines.poll(pollTimeoutInMs,TimeUnit.MILLISECONDS);
}

protected SourceRecord consumeRecord ( ) throws InterruptedException { return consumedLines . poll ( pollTimeoutInMs , TimeUnit . MILLISECONDS ) ; }
consume a single record from the connector .
