因此，我们计划使用avro在一个融合了kafka的生态系统上进行通信。我目前对avro的理解是，每条消息都有自己的模式。如果是这样的话，我们需要模式注册表来解决版本更新吗？我之所以这样问，是因为在每条消息中都带有模式，这样就不需要模式注册表之类的东西来将消息idMap到模式。还是我在这里遗漏了什么？
2cmtqfgy1#
运行合流模式注册表时，与合流avro serdes库一起发布的kafka消息不包含avro模式。它们只包含消费者反序列化程序用于从合流模式注册表中获取模式的数字模式id。这些模式由序列化程序和反序列化程序缓存，作为进一步的性能优化。
1条答案
按热度按时间2cmtqfgy1#
运行合流模式注册表时，与合流avro serdes库一起发布的kafka消息不包含avro模式。它们只包含消费者反序列化程序用于从合流模式注册表中获取模式的数字模式id。这些模式由序列化程序和反序列化程序缓存，作为进一步的性能优化。