public KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T, U> pipeline,
        KinesisConnectorConfiguration configuration) {
    this.configuration = configuration;
    this.pipeline = pipeline;
}