-
Initiates the building of a streaming source that consumes a
Kinesis data stream and emits Map.Entry<String, byte[]>
items.
Specifies the AWS credentials to use for authentication
purposes.
Specifies the AWS Kinesis endpoint (URL of the entry point
for the AWS web service) to connect to.
Specifies an executor service supplier that will be used by the AwsConfig
to construct an AWS async client.
Specifies how initial reads of the shards should be done (see
shardIteratorType for available options).
KinesisSources.Builder.withProjectionFn(BiFunctionEx<com.amazonaws.services.kinesis.model.Record,com.amazonaws.services.kinesis.model.Shard,T_NEW> projectionFn)
Specifies projection function, that will map input Record
and Shard from which this record was read into user-defined type.
Specifies the AWS Region (collection of AWS resources in a
geographic area) to connect to.
Specifies how the source should behave when reading data from
the stream fails.