code: @VisibleForTesting
  	protected ConsumerRecords<byte[], byte[]> getRecordsFromKafka() {
  		ConsumerRecords<byte[], byte[]> records = consumer.poll(pollTimeout);
  		if (rateLimiter != null) {
  			int bytesRead = getRecordBatchSize(records);
  			rateLimiter.acquire(bytesRead);
  		}
  		return records;
  	}
docs: Get records from Kafka. If the rate-limiting feature is turned on, this method is called at
  a rate specified by the {@link #rateLimiter}.
  @return ConsumerRecords