java - 带有 IAM 的 AWS MSK - 超时异常

Question

我们正在使用 Aws MSK，最近他们宣布了 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 可以工作，但似乎缺少某些东西，有什么建议吗？

Answer 1

我有这个问题。 AWS MSK IAM 依赖于 communication over port 9098 .就我而言，我的安全组允许通过典型端口 9092(纯文本)和 9094(TLS)但不是 9098 的入站通信。确保您的集群接受通过该端口的流量