我们正在使用 Aws MSK，最近他们宣布了 AWS MSK IAM AUTH(https://github.com/aws/aws-msk-iam-auth https://github.com/aws/aws-msk-iam-auth)
当我尝试在客户端上使用以下配置时，我得到了异常：
org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata, deadlineMs=1620677932733) timed out at 1620677932734 after 1 attempt(s)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
我的应用程序.yml：
sasl:
mechanism: AWS_MSK_IAM
jaas:
config: software.amazon.msk.auth.iam.IAMLoginModule required
client:
callback:
handler:
class: software.amazon.msk.auth.iam.IAMClientCallbackHandler
telnet 可以工作，但似乎缺少一些东西，有什么建议吗？
我有这个问题。 AWS MSK IAM 依赖通过端口 9098 进行通信 https://aws.amazon.com/blogs/big-data/securing-apache-kafka-is-easy-and-familiar-with-iam-access-control-for-amazon-msk/。就我而言，我的安全组允许通过典型端口 9092（纯文本）和 9094 (TLS) 进行入站通信，但不允许通过 9098。确保您的集群正在接受通过该端口的流量
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
