exceptionfactory commented on code in PR #6846:
URL: https://github.com/apache/nifi/pull/6846#discussion_r1071371445
##########
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-shared/src/main/java/org/apache/nifi/kafka/shared/component/KafkaClientComponent.java:
##########
@@ -107,6 +107,35 @@ public interface KafkaClientComponent {
)
.build();
+ PropertyDescriptor AWS_PROFILE_NAME = new PropertyDescriptor.Builder()
+ .name("aws.profile.name")
+ .displayName("AWS Profile Name")
+ .description("The AWS Profile to consider when there are multiple
profiles available.")
+ .dependsOn(
+ SASL_MECHANISM,
+ SaslMechanism.AWS_MSK_IAM
+ )
+ .required(false)
+ .addValidator(StandardValidators.NON_BLANK_VALIDATOR)
+
.expressionLanguageSupported(ExpressionLanguageScope.VARIABLE_REGISTRY)
+ .build();
+
+ PropertyDescriptor AWS_DEBUG_CREDS = new PropertyDescriptor.Builder()
+ .name("aws.debug.creds")
+ .displayName("Debug AWS Credentials")
+ .description("This property helps to debug which AWS credential is
being exactly used. If this property is set to true "
+ + "and
`software.amazon.msk.auth.iam.internals.MSKCredentialProvider` logger is set to
DEBUG, a log will be printed "
+ + "including IAM Account, IAM user id and the ARN of the
IAM Principal corresponding to the credential being used. "
+ + "It is recommended to use this property only during
debug since it makes an additional remote call.")
Review Comment:
One potential option could be to pass the debug status for the associated
Processor's ComponentLog, although that would require some additional wiring.
Either way, I agree that this is not ideal as a Processor property.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
