in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java [153:158]
public DynamoDBReplicationEmitter(final String applicationName, final String endpoint, final String region, final String tableName,
final AmazonCloudWatchAsync cloudwatch, final AWSCredentialsProvider credentialProvider) {
this(applicationName, endpoint, region, tableName,
new AmazonDynamoDBAsyncClient(credentialProvider, new ClientConfiguration().withMaxConnections(MAX_THREADS).withRetryPolicy(PredefinedRetryPolicies.DYNAMODB_DEFAULT), Executors.newFixedThreadPool(MAX_THREADS)),
cloudwatch);
}