我们在 kafka 主题中使用 Avro 方案,它代表“公共”接口。当这样的主题现在在 Kafka-Streams 应用程序中使用并调用有状态操作时,相同的模式会自动再次使用内部名称注册。
处理这个问题的常用方法是什么?这些主题和状态存储永远不会被我的应用程序以外的任何人使用,因此我不认为将该架构发布到注册表有什么意义。有没有办法只使用一些本地可用的模式,或者至少不再为每个内部主题多次发布模式?
我认为最好的解决方案是通过设置配置参数
auto.register.schemas=false
来禁用自动架构注册,并改用架构注册表。
PS: auto.register.schemas=false 应该在客户端设置
参见 https://docs.confluence.io/platform/current/schema-registry/security/index.html