luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Dead code removed

Browse source
This commit is contained in:
Meher Mankikar 2023-06-15 09:24:35 -07:00
parent eb07782f4f
commit 8dcbb75031
1 changed files with 0 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java
View file

@ -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;
/**