amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactory.java [75:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				startingPosition,
				streamShardHandle,
				metricsReporter,
				kinesisProxy,
				configuration.getMaxNumberOfRecordsPerFetch(),
				configuration.getFetchIntervalMillis());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactory.java [83:88]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				startingPosition,
				streamShardHandle,
				metricsReporter,
				kinesisProxy,
				configuration.getMaxNumberOfRecordsPerFetch(),
				configuration.getFetchIntervalMillis());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -