diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java index c3cf2e5b..cf1902ab 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java @@ -140,7 +140,6 @@ public interface KCLAppConfig { } default ConfigsBuilder getConfigsBuilder() throws IOException, URISyntaxException { -// return getConfigsBuilder(""); final String workerId = getWorkerId(); if (getStreamArn() == null) { return new ConfigsBuilder(getStreamName(), getApplicationName(), buildConsumerClient(), buildAsyncDynamoDbClient(), @@ -151,17 +150,6 @@ public interface KCLAppConfig { } } -// default ConfigsBuilder getConfigsBuilder(String workerIdSuffix) throws IOException, URISyntaxException { -// final String workerId = getWorkerId() + workerIdSuffix; -// if (getStreamArn() == null) { -// return new ConfigsBuilder(getStreamName(), getApplicationName(), buildConsumerClient(), buildAsyncDynamoDbClient(), -// buildAsyncCloudWatchClient(), workerId, getShardRecordProcessorFactory()); -// } else { -// return new ConfigsBuilder(Arn.fromString(getStreamArn()), getApplicationName(), buildConsumerClient(), buildAsyncDynamoDbClient(), -// buildAsyncCloudWatchClient(), workerId, getShardRecordProcessorFactory()); -// } -// } - RetrievalConfig getRetrievalConfig() throws IOException, URISyntaxException; /**