Robust Message Serialization in Apache Kafka Using Apache Avro, Part 2
-
Implementing a Schema Store
In Part 1, we saw the need for an Apache Avro schema provider but did not implement one. In this part we will implement a schema provider that works with Apache Kafka as storage.
In-Memory SchemaStore
First we can implement an in-memory store for schemas. This is useful to understand the requirements for such a store and as the cache of the Kafka backed store. A SchemaStore has to be quick in looking up VersionedSchema entries.
The post Robust Message Serialization in Apache Kafka Using Apache Avro, Part 2 appeared first on Cloudera Engineering Blog.
http://blog.cloudera.com/blog/2018/07/robust-message-serialization-in-apache-kafka-using-apache-avro-part-2/
© Lightnetics 2024