class PollingRecordPublisher implements RecordPublisher {

	@Override
	public RecordPublisherRunResult run(final RecordBatchConsumer consumer) throws InterruptedException {
		return run(consumer, maxNumberOfRecordsPerFetch);
	}

	  PollingRecordPublisher(
			final StartingPosition startingPosition,
			final StreamShardHandle subscribedShard,
			final PollingRecordPublisherMetricsReporter metricsReporter,
			final KinesisProxyInterface kinesisProxy,
			final int maxNumberOfRecordsPerFetch,
			final long expiredIteratorBackoffMillis);

}