AWS Node JS kafka消费者解密kafka消息的代码示例

Question

Kafka 生产者生产记录，我想在节点 JS lambda 中使用这些记录。制作人说他们正在使用 AES 256 密钥的 confluent Envelope 加密，并与我们共享 RSA 公钥来解密它们

任何在节点 JS 中有代码示例的人

1. 与 kafka 消费者联系
2. 解密负载
3. 来自 kafka 消费者的投票记录

非常感谢您的帮助。

Answer 1

1. Kafka JS 库用于消费记录但未成功。所以 Kafka 触发器被添加到 lambda 中
2. 使用加密库完成解密
3. 按照 KAfka Js 库示例进行轮询记录。