Kafka Lambda触发器（EventSourceMapping）-密钥中的凭据未刷新

Question

【以下的问题经过翻译处理】 你好，我正在使用Kafka触发器（Cloudformation EventSourceMapping）将自定义Kafka集群集成到AWS Lambda中。

如果我重置Kafka集群的密码并随后更新在EventSourceMapping中使用的密钥，则EventSourceMapping不会重新获取/刷新该密钥。

相反，EventSourceMapping仍在尝试使用旧的密钥版本（使用旧密码），这会导致错误：
```
Last processing result: PROBLEM: SASL authentication failed.
```
由于这个问题，没有事件被传递到lambda函数。

由于我将密钥的ARN传递给EventSourceMapping，并授予Lambda获取此密钥的权限，我期望EventSourceMapping会定期自动刷新/重新获取密钥。

然而，我需要做的是删除EventSourceMapping（触发器）并再次创建它（具有相同的配置）。这是不可接受的，因为我们的Kafka集群会使用多个Lambda集成，在密码（和上述密钥）更改后删除/重新创建Lambda集成是非常低效的。

Answer

【以下的回答经过翻译处理】 你好，

我了解到你正在使用Lambda的Kafka Event Source Mapping。你通过将新的凭证密钥与Kafka集群关联，对现有Kafka集群的密码进行了重置。在此之后，你更新了Lambda Event Source Mapping中的凭证密钥。然而，Lambda事件源似乎仍在使用先前的凭证密钥，并且没有自动重新获取/刷新新的凭证密钥，导致SASL身份验证失败错误。如果我有任何误解，请纠正我。

我在我的AWS账户中尝试复制此操作，我创建了一个新的凭证密钥，将新的凭证密钥与Kafka集群关联。进一步地，我将Kafka客户端的用户名/密码更新为与新的凭证密钥中的值匹配。最后，我更新了Lambda事件源映射以使用新的凭证密钥ARN。下面是我用来更新事件源的CLI命令：

```
$ aws lambda update-event-source-mapping --uuid  --function-name  --source-access-configurations "Type"="SASL_SCRAM_512_AUTH","URI"="

Kafka Lambda触发器（EventSourceMapping）-密钥中的凭据未刷新

相关内容