【发布时间】:2018-11-11 18:12:36
【问题描述】:
我正在尝试将 Avro 和 Schema Registry 集成到我们的 Kafka 数据管道中。现在它在 Go 服务内部看起来像
获取数据 -> 将数据编码为 JSON -> 写入 Kafka
我想以同样的方式使用 avro 架构
生成架构 -> 更新架构注册表中的架构 -> 获取数据 -> 编码为 Avro -> 写入 Kafka
但是有几个问题:
- 如何自动从 Go 类生成架构?
- 我应该如何检查架构与架构注册表的兼容性?
【问题讨论】:
-
您是否查看过执行此操作的库?例如github.com/linkedin/goavro
-
Schema Registry 有一个记录在案的 API 用于兼容性检查
-
@JohnGiotta 他们不这样做。我的意思是从 go 代码生成 avro 模式?
标签: go apache-kafka avro confluent-schema-registry