| Package | Description |
|---|---|
| software.amazon.kinesis.common | |
| software.amazon.kinesis.coordinator |
| Constructor and Description |
|---|
ConfigsBuilder(@NonNull MultiStreamTracker multiStreamTracker,
@NonNull String applicationName,
@NonNull software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisClient,
@NonNull software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDBClient,
@NonNull software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient cloudWatchClient,
@NonNull String workerIdentifier,
@NonNull ShardRecordProcessorFactory shardRecordProcessorFactory)
Constructor to initialize ConfigsBuilder with MultiStreamTracker
|
ConfigsBuilder(@NonNull String streamName,
@NonNull String applicationName,
@NonNull software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisClient,
@NonNull software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDBClient,
@NonNull software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient cloudWatchClient,
@NonNull String workerIdentifier,
@NonNull ShardRecordProcessorFactory shardRecordProcessorFactory)
Constructor to initialize ConfigsBuilder with StreamName
|
| Modifier and Type | Method and Description |
|---|---|
protected ShardConsumer |
Scheduler.buildConsumer(@NonNull ShardInfo shardInfo,
@NonNull ShardRecordProcessorFactory shardRecordProcessorFactory,
@NonNull LeaseCleanupManager leaseCleanupManager) |
Copyright © 2022. All rights reserved.