public void enqueue(SourceRecord record) throws InterruptedException {
  if (record != null) {
    records.put(record);
  }
}

public void enqueue ( SourceRecord record ) throws InterruptedException { if ( record != null ) { records . put ( record ) ; } }
adds the event into the queue for subsequent batch processing .
