时间戳

首页 > 解决方案 > 带 IAM 的 AWS MSK - 超时异常

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

问题描述

我们正在使用 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 有效，但似乎缺少某些东西，有什么建议吗？

标签： javaamazon-web-servicesspring-bootkotlinaws-msk

解决方案

我有这个问题。AWS MSK IAM 依赖于端口 9098 上的通信。就我而言，我的安全组允许通过典型端口 9092（明文）和 9094（TLS）进行入站通信，但不允许通过 9098。确保您的集群接受该端口上的流量

推荐阅读