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

Improve logging for failed/successful credential creation

Browse source
This commit is contained in:
Ethan Katnic 2024-11-04 12:53:15 -08:00
parent c27744d789
commit 210d61a843
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoder.java
View file

@ -57,6 +57,10 @@ class AwsCredentialsProviderPropertyValueDecoder implements IPropertyValueDecode
List<AwsCredentialsProvider> providers = getValidCredentialsProviders(providerNames); List<AwsCredentialsProvider> providers = getValidCredentialsProviders(providerNames);
AwsCredentialsProvider[] ps = new AwsCredentialsProvider[providers.size()]; AwsCredentialsProvider[] ps = new AwsCredentialsProvider[providers.size()];
providers.toArray(ps); providers.toArray(ps);
if (providers.isEmpty()) {
log.warn("Unable to construct any provider with name {}", value);
log.warn("Please verify that all AwsCredentialsProvider properties are passed correctly");
}
return AwsCredentialsProviderChain.builder() return AwsCredentialsProviderChain.builder()
.credentialsProviders(providers) .credentialsProviders(providers)
.build(); .build();
@ -93,6 +97,7 @@ class AwsCredentialsProviderPropertyValueDecoder implements IPropertyValueDecode
provider = tryCreate(providerName, clazz, varargs); provider = tryCreate(providerName, clazz, varargs);
} }
if (provider != null) { if (provider != null) {
log.info("Provider constructed successfully: {}", provider);
credentialsProviders.add(provider); credentialsProviders.add(provider);
} }
} }
@ -244,10 +249,12 @@ class AwsCredentialsProviderPropertyValueDecoder implements IPropertyValueDecode
final String providerName, final CredentialsProviderConstructor<T> constructor) { final String providerName, final CredentialsProviderConstructor<T> constructor) {
try { try {
return constructor.construct(); return constructor.construct();
} catch (NoSuchMethodException ignored) { } catch (NoSuchMethodException
| IllegalAccessException
| InstantiationException
| InvocationTargetException
| RuntimeException ignored) {
// ignore // ignore
} catch (IllegalAccessException | InstantiationException | InvocationTargetException | RuntimeException e) {
log.warn("Failed to construct {}", providerName, e);
} }
return null; return null;
} }