class FanOutRecordPublisher implements RecordPublisher {

	private List<com.amazonaws.services.kinesis.model.Record> toSdkV1Records(final List<Record> records) {
		final List<com.amazonaws.services.kinesis.model.Record> sdkV1Records = new ArrayList<>();

		for (Record record : records) {
			sdkV1Records.add(toSdkV1Record(record));
		}

		return sdkV1Records;
	}

	public  FanOutRecordPublisher(
			final StartingPosition startingPosition,
			final String consumerArn,
			final StreamShardHandle subscribedShard,
			final KinesisProxyV2Interface kinesisProxy,
			final FanOutRecordPublisherConfiguration configuration,
			final FullJitterBackoff backoff);

}