如何处理内部 kafka-streams 主题的 avro 架构?

问题描述 投票:0回答:1

我们在 kafka 主题中使用 Avro 方案,它代表“公共”接口。当这样的主题现在在 Kafka-Streams 应用程序中使用并调用有状态操作时,相同的模式会自动再次使用内部名称注册。

处理这个问题的常用方法是什么?这些主题和状态存储永远不会被我的应用程序以外的任何人使用,因此我不认为将该架构发布到注册表有什么意义。有没有办法只使用一些本地可用的模式,或者至少不再为每个内部主题多次发布模式?

apache-kafka apache-kafka-streams avro spring-cloud-stream confluent-schema-registry
1个回答
-1
投票

我认为最好的解决方案是通过设置配置参数

auto.register.schemas=false
来禁用自动架构注册,并改用架构注册表。

PS: auto.register.schemas=false 应该在客户端设置

参见 https://docs.confluence.io/platform/current/schema-registry/security/index.html

© www.soinside.com 2019 - 2024. All rights reserved.