Enables developers to use AWS Identity and Access Management (IAM) to connect to their Amazon Managed Streaming for Apache Kafka (Amazon MSK) clusters.
We are reverting the commits as we are seeing the following issue where passing only awsRoleArn to Jaas config without using an overrided awsStsRegion.
An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Failed to find AWS IAM Credentials [Caused by aws_msk_iam_auth_shadow.com.amazonaws.services.securitytoken.model.AWSSecurityTokenServiceException: Credential should be scoped to a valid region. (Service: AWSSecurityTokenService; Status Code: 403; Error Code: SignatureDoesNotMatch; Request ID: 14905a5d-2bf2-4ff1-976a-c7d7ca5b9a02; Proxy: null)]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector)
Revert "Remove formatting" This reverts commit 45be4a59cd0784754cab14a1a2b4e40314b1588f.
Revert "use API to get ServiceEndpoint" This reverts commit e68c800529273ab63a89d98d659955aca8c85e8c.
We are reverting the commits as we are seeing the following issue where passing only
awsRoleArnto Jaas config without using an overridedawsStsRegion.Issue #, if available:
Description of changes:
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.