連接到AWS MSK的

[Sudhir1]

如何連接到基於AWS MSK的已到底的身份驗證?

[karthik_p]

@Sudhir賈斯瓦爾請檢查以下stackflow msk的相關鏈接,下載新的jar文件我和連接到集群,您將使用和添加讀取配置並提供主題名稱和其他細節

https://stackoverflow.com/questions/69772612/kafka-consumer-using-aws-msk-iam-classcastexception-err..。

[Sudhir1]

@karthik_p

似乎我和提到的方法取得了一些進展。但我得到一個錯誤:

引起的:kafkashaded.org.apache.kafka.common.errors.SaslAuthenticationException: [dabd4181 - e46b 4 - 18 - 8 e01 - 87 b4a0ec9f5a):拒絕訪問

我想知道還有什麼我錯過!

[judyy]

嗨,戀人,

我跟著這個解決方案,但是有這樣的錯誤:SaslAuthenticationException:一個錯誤:(java.security。PrivilegedActionException: javax.security.sasl。SaslException:沒有找到AWS我憑證(由aws_msk_iam_auth_shadow.com.amazonaws.SdkClientException:無法加載AWS憑證鏈中的任何提供者:[aws_msk_iam_auth_shadow.com.amazonaws.auth.AWSCredentialsProviderChain@62c66486:無法加載AWS憑證鏈中的任何提供者:[EnvironmentVariableCredentialsProvider:無法加載AWS憑證從環境變量(AWS_ACCESS_KEY_ID(或AWS_ACCESS_KEY)和AWS_SECRET_KEY(或AWS_SECRET_ACCESS_KEY)), SystemPropertiesCredentialsProvider:無法加載從Java係統屬性(AWS AWS憑據。accessKeyId aws.secretKey), WebIdentityTokenCredentialsProvider:你必須指定一個值roleArn和roleSessionName software.amazon.msk.auth.iam.internals.EnhancedProfileCredentialsProvider@7881f590:概要文件包含沒有憑證檔案“默認”:ProfileFile(資料= []),aws_msk_iam_auth_shadow.com.amazonaws.auth.EC2ContainerCredentialsProviderWrapper@362f07a1:沒有找到所請求的元數據在http://169.254.169.254/latest/meta-data/iam/security-credentials/]]])發生在評估收到卡夫卡代理SASL令牌。卡夫卡的客戶會去AUTHENTICATION_FAILED狀態。

但是我已經設置OS環境下麵代碼:

操作係統。環境(' AWS_ACCESS_KEY_ID '] = " AKID "

操作係統。環境(' AWS_SECRET_ACCESS_KEY '] = " XXXXXXXXXXXX "

你能給我任何的見解嗎?提前感謝!

[judyy]

我修複這個錯誤通過添加2環境變量在集群配置- >高級選項- >環境變量:

AWS_SECRET_ACCESS_KEY = " XXXXXX "

AWS_ACCESS_KEY_ID =“XXXX”

AWS_DEFAULT_REGION =“XXXX”