【发布时间】：2019-06-01 19:12:29
【问题描述】：
据我了解，Avro 模式将缓存在本地，消费者将从本地缓存中使用反序列化过程。在此过程中，如果出现异常情况，例如 avro 架构未缓存在本地。会发生什么？
会继续尝试从模式服务器读取吗？如果是这样，它将被尝试多少次？还是其他场景？
【问题讨论】：
标签： apache-kafka avro confluent-platform confluent-schema-registry
【发布时间】：2019-06-01 19:12:29
【问题描述】：
消息是使用架构 ID 而不是整个架构编写的。当消费者第一次读取数据时，它会获取模式 id 并向模式注册表请求相应的模式。消费者将缓存模式并为其他消息进行映射。
【讨论】：
-
感谢您的回复。另一个快速的问题，如果消费者由于某些问题在本地缓存模式失败，会发生什么。它会继续发送架构 ID 还是会失败？
-
如果你在你的消费者中使用
KafkaAvroDeserializer，你会得到一个SerializationException。见serializer