code: @Override
  	protected ShardConsumer createShardConsumer(
  		Integer subscribedShardStateIndex,
  		StreamShardHandle handle,
  		SequenceNumber lastSeqNum,
  		ShardMetricsReporter shardMetricsReporter) {
  
  		return new ShardConsumer(
  			this,
  			subscribedShardStateIndex,
  			handle,
  			lastSeqNum,
  			DynamoDBStreamsProxy.create(getConsumerConfiguration()),
  			shardMetricsReporter);
  	}
docs: Create a new DynamoDB streams shard consumer.
  
  @param subscribedShardStateIndex the state index of the shard this consumer is subscribed to
  @param handle stream handle
  @param lastSeqNum last sequence number
  @param shardMetricsReporter the reporter to report metrics to
  @return