第56章 Avro Jackson

Jackson Avro は、Avro エクステンションとともに Jackson ライブラリーを使用して Avro ペイロードを Java オブジェクトにアンマーシャリングするか、Java オブジェクトを Avro ペイロードにマーシャリングするデータ形式です。

注記

Jackson に精通している場合、この Avro データ形式は JSON の対応する方法と同じように動作するため、JSON シリアライゼーション/デシリアライズにアノテーションが付けられたクラスで使用できます。

from("kafka:topic").
  unmarshal().avro(AvroLibrary.Jackson, JsonNode.class).
  to("log:info");

from("kafka:topic").
  unmarshal().avro(AvroLibrary.Jackson, JsonNode.class).
  to("log:info");

Copy to Clipboard

Toggle word wrap

56.1. SchemaResolver の設定
リンクのコピー

Avro シリアライゼーションはスキーマベースであるため、このデータ形式は、マーシャリング/アンマーシャリングされるエクスチェンジごとにスキーマをルックアップできる SchemaResolver オブジェクトを提供する必要があります。

単一の SchemaResolver をレジストリーに追加して、自動的に検索されます。または、カスタム SchemaResolver への参照を明示的に指定できます。

トップに戻る