スキーマを使用したAvroメッセージ

Question

したがって、コンフルエントなカフカベースのエコシステムでAvroを使用して通信する予定です。 Avroの私の現在の理解は、各メッセージがそのスキーマを運ぶことです。その場合、バージョンの更新を解決するためだけにスキーマレジストリが必要ですか？

各メッセージでスキーマを運ぶと、スキーマレジストリのようにメッセージIDをスキーマにマップする必要がなくなるので、私は尋ねます。または私はここに何かを逃していますか？

Answer 1

Confluent Schema Registryを実行すると、Confluent Avro Serdesライブラリで公開されたKafkaメッセージには、avroスキーマが含まれません。コンシューマデシリアライザがコンフルエントスキーマレジストリからスキーマをフェッチするために使用する数字のスキーマIDのみが含まれています。これらのスキーマは、パフォーマンスの最適化としてシリアライザとデシリアライザによってキャッシュされます。