nrnalamalpu commented on a change in pull request #5291:
URL: https://github.com/apache/nifi/pull/5291#discussion_r796860824
##########
File path:
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
##########
@@ -611,6 +642,29 @@ private static void setScramJaasConfig(final Map<String,
Object> mapToPopulate,
mapToPopulate.put(SaslConfigs.SASL_JAAS_CONFIG, builder.toString());
}
+ /**
+ * New function created to support IAM JASS configuration.
+ */
+ private static void setIamJaasConfig(final Map<String, Object>
mapToPopulate, final ProcessContext context) {
+ final String awsProfileName =
context.getProperty(AWS_PROFILE_NAME).evaluateAttributeExpressions().getValue();
+ final String awsRoleArn =
context.getProperty(AWS_ROLE_ARN).evaluateAttributeExpressions().getValue();
+ final String awsSessionName =
context.getProperty(AWS_SESSION_NAME).evaluateAttributeExpressions().getValue();
+
+ final StringBuilder builder = new
StringBuilder("software.amazon.msk.auth.iam.IAMLoginModule required ");
Review comment:
We tested the functionality by adding the jar file in the classpath.
But, I agree and add the pom dependency.
--
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]
