1.6. スキーマと Java クライアントシリアライザー/デシリアライザーを使用した Kafka メッセージの検証

Kafka プロデューサーアプリケーションは、シリアライザーを使用して、特定のイベントスキーマに準拠するメッセージをエンコードできます。Kafka コンシューマーアプリケーションはデシリアライザーを使用して、特定のスキーマ ID に基づいてメッセージが適切なスキーマを使用してシリアライズされたことを検証できます。

図1.2 Service Registry および Kafka クライアント SerDes アーキテクチャー

Service Registry は、実行時に以下のメッセージタイプを検証するために Kafka クライアントシリアライザー/デシリアライザー (SerDes) を提供します。

Service Registry の Maven リポジトリーとソースコードの配布には、これらのメッセージタイプの Kafka SerDes 実装が含まれており、Kafka クライアントアプリケーションの開発者は、これを使用して、Service Registry と統合できます。

これらの実装には、サポートされている各メッセージタイプのカスタム Java クラスが含まれています。たとえば、io.apicurio.registry.serde.avro などです。クライアントアプリケーションは、検証のために実行時に Service Registry からスキーマをプルするために使用できます。