@ Override protected ShardConsumer createShardConsumer ( Integer subscribedShardStateIndex , StreamShardHandle handle , SequenceNumber lastSeqNum , ShardMetricsReporter shardMetricsReporter ) { return new ShardConsumer ( this , subscribedShardStateIndex , handle , lastSeqNum , DynamoDBStreamsProxy . create ( getConsumerConfiguration ( ) ) , shardMetricsReporter ) ; }
Create a new DynamoDB streams shard consumer .