如何使用 ssl 捆绑配置 kafka Schema 注册表客户端

Question

我正在寻找一种使用 ssl 捆绑包配置架构注册表客户端的方法。

我有一个向 kafka 主题发送消息的应用程序。 生产者使用密钥库和信任信息进行配置，一切正常。 现在，我需要将配置切换为使用 ssl 捆绑包。 我能够配置生产者，但是，我没有找到配置架构注册表客户端的方法。 有办法做到这一点吗？

在 application.yml 文件中，我尝试了以下操作：

spring.kafka.properties.schema.registry.url =  ........ spring.kafka.properties.schema.registry.ssl.bundle = theBundle

但是客户端无法连接到registry。

Answer 1

无法完成。架构注册表（scala 客户端）要求证书在文件系统上可用