Package | Description |
---|---|
com.hazelcast.jet.kinesis |
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
|
Modifier and Type | Method and Description |
---|---|
static KinesisSources.Builder |
KinesisSources.kinesis(String stream)
Initiates the building of a streaming source that consumes a
Kinesis data stream and emits
Map.Entry<String, byte[]>
items. |
KinesisSources.Builder |
KinesisSources.Builder.withCredentials(String accessKey,
String secretKey)
Specifies the AWS credentials to use for authentication
purposes.
|
KinesisSources.Builder |
KinesisSources.Builder.withEndpoint(String endpoint)
Specifies the AWS Kinesis endpoint (URL of the entry point
for the AWS web service) to connect to.
|
KinesisSources.Builder |
KinesisSources.Builder.withInitialShardIteratorRule(String shardIdRegExp,
String shardIteratorType,
String parameter)
Specifies how initial reads of the shards should be done (see
shardIteratorType for available options).
|
KinesisSources.Builder |
KinesisSources.Builder.withRegion(String region)
Specifies the AWS Region (collection of AWS resources in a
geographic area) to connect to.
|
KinesisSources.Builder |
KinesisSources.Builder.withRetryStrategy(RetryStrategy retryStrategy)
Specifies how the source should behave when reading data from
the stream fails.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.