org.apache.flink.streaming.connectors.kinesis.internals

Interface KinesisDataFetcher.FlinkKinesisProxyV2Factory

Enclosing class:

KinesisDataFetcher<T>

public static interface KinesisDataFetcher.FlinkKinesisProxyV2Factory

Factory to create Kinesis proxy V@ instances used by a fetcher.

Method Summary

Modifier and Type	Method and Description
KinesisProxyV2Interface	create(Properties configProps)

Method Detail

create

KinesisProxyV2Interface create(Properties configProps)