带有模式的Avro消息
因此，我们计划使用Avro在融合的Kafka生态系统上进行交流。我目前对Avro的理解是，每条消息都有自己的模式。如果是这样的话，我们需要模式注册表来解决版本更新吗？
我问，因为在每条消息中携带模式可以防止需要像模式注册表这样的东西来将消息ID映射到模式。还是我在这里错过了什么？
共有1个答案
运行Confluent Schema注册表时，与Confluent Avro Serdes库一起发布的Kafka消息不包含Avro模式。它们只包含一个数字模式id，消费者反序列化程序使用该id从汇合模式注册表中获取模式。这些模式由序列化程序和反序列化程序缓存，作为进一步的性能优化。
-
我们使用Apache Kafka（不是confluent Kafka)0.10。我们想用Kafka设置AVRO模式。我有如下的avro模式。 序列化消息, 这正像预期的那样起作用。 但是,希望在主题级别设置一个Avro模式,这样,如果消息不符合Avro模式,主题将拒绝消息。 不管怎么说，我可以用阿帕奇Kafka0.10做到这一点。
-
大家好，我需要为下面的示例创建AVRO模式； 当我按照建议更改所有者对象时，avro-tool返回错误。 ]} 测试：
-
我正在使用带有Avro和汇流模式注册表的Spring云流。我正在为所有服务使用一个单独的DLQ主题，因此具有不同模式的消息可能会落在这个主题中。我已禁用动态架构注册，以确保不传递错误消息()。 然而，问题是由于dlq上缺少模式，我可能会在进入这个主题时丢失一条消息。因此，我希望能够以JSON格式向dlq生成消息，并在管道的其余部分使用Avro。如果有人能帮助我如何做到这一点，或者能为我指出这件事的
-
我想知道下面的模式对于Avro模式是否有效。请注意，字段数组的第一个对象中缺少名称。 它实际上是针对以下类型的数据设计的 根据下面的阅读，似乎没有名字的数组是不允许的 Avro架构失败 https://avro.apache.org/docs/current/spec.html#schema_complex 我怀疑下面是正确的 它应该有如下数据，以便成功进行avro转换 下面的模式是否有效？在第一
-
我有两个问题： > 我曾尝试使用模式V1编写记录，并使用模式V2读取记录，但出现以下错误： org.apache.avro。AvroTypeException：找到foo，应为foo 我使用avro-1.7.3和： 以下是这两种模式的示例（我也尝试过添加命名空间，但没有成功）。 架构V1： 架构V2： 提前谢谢。