protected KinesisDataFetcher<T> createFetcher(
			List<String> streams,
			SourceFunction.SourceContext<T> sourceContext,
			RuntimeContext runtimeContext,
			Properties configProps,
			KinesisDeserializationSchema<T> deserializationSchema) {

		return new KinesisDataFetcher<>(streams, sourceContext, runtimeContext, configProps, deserializationSchema, shardAssigner, periodicWatermarkAssigner);
	}
protected KinesisDataFetcher < T > createFetcher ( List < String > streams , SourceFunction . SourceContext < T > sourceContext , RuntimeContext runtimeContext , Properties configProps , KinesisDeserializationSchema < T > deserializationSchema ) { return new KinesisDataFetcher < > ( streams , sourceContext , runtimeContext , configProps , deserializationSchema , shardAssigner , periodicWatermarkAssigner ) ; }
This method is exposed for tests that need to mock the KinesisDataFetcher in the consumer.