我有一个MSK集群和MSK连接连接器的设置(这是一个到postgres数据库的源连接器，但这在这里不重要(。
在我设置的第一步中，它在没有身份验证的情况下进行了设置。而且效果很好。
现在，作为我的下一步，我介绍了基于TLS和IAM的身份验证。但我最终得到了"org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: fetchMetadata"
我已经尝试了使用IAM的AWS MSK的所有答案-超时异常。
我具体做了什么：我给了我的Connect Cluster额外的AWS管理策略"；AmazonMSKFullAccess"；，因此它可以在MSK上执行所有动作。然后我将出站和入站规则添加到我的MSK集群的安全组中，这样就可以从同一安全组中访问9098端口。
在我更新了MSK集群的配置以便只支持IAM身份验证之后，我特别没有重新创建连接器(假设这不是必要的(。
有人知道可能缺少什么吗？
致以最良好的问候
Andy
这是我的错。旧的连接器仍然设置为未经身份验证的访问-我需要用身份验证方法创建一个新的连接器"；IAM"；。