我正试图在Confluent (Kafka)中创建一个带有ksqlDB的MongoDB 连接器接收器。问题是我在AWS秘密管理器中有数据源和凭据。
是否有一种方法可以通过ksqlDB获取秘密来设置连接器属性?
发布于 2022-07-27 13:27:16
卡夫卡连接支持外化配置的秘密。对于AWS是否存在这样的实现,我不确定,但如果不存在,则需要为其编写自己的ConfigProvider
。
另外,也可能有其他解决方案,例如在MSK、ECS、EC2或EKS中运行ksql或仅连接自身,在这些解决方案中,您可以将秘密管理器数据公开到文件或环境变量中,然后由Connect的默认配置提供程序使用这些进程,然后在外部设置ksql以指向这些连接实例,或者只处理它输出的主题。
https://stackoverflow.com/questions/73134562
复制相似问题