Red Hat Summit第8章 Java クライアントでの Kafka シリアライザー/デシリアライザーの設定
本章では、プロデューサーおよびコンシューマー Java クライアントアプリケーションで Kafka SerDes を設定する方法について詳しく説明します。
8.1. クライアントアプリケーションの Apicurio Registry シリアライザー/デシリアライザーの設定
本セクションの定数例を使用して、特定のクライアントシリアライザー/デシリアライザー (SerDe) サービスおよびスキーマ検索ストラテジーを直接クライアントアプリケーションに設定できます。または、ファイルまたはインスタンスで対応する Apicurio Registry アプリケーションプロパティーを設定できます。
以下のセクションでは、一般的に使用される SerDe 定数および設定オプションの例を紹介します。
SerDe サービスの設定
public class SerdeConfig {
public static final String REGISTRY_URL = "apicurio.registry.url"; 1
public static final String ID_HANDLER = "apicurio.registry.id-handler"; 2
public static final String ENABLE_CONFLUENT_ID_HANDLER = "apicurio.registry.as-confluent"; 3関連情報
- 設定オプションの詳細は、「Apicurio Registry シリアライザー/デシリアライザーの設定プロパティー」 を参照してください。
SerDe 検索ストラテジーの設定
public class SerdeConfig {
public static final String ARTIFACT_RESOLVER_STRATEGY = "apicurio.registry.artifact-resolver-strategy"; 1
public static final String SCHEMA_RESOLVER = "apicurio.registry.schema-resolver"; 2
...関連情報
- 検索ストラテジーの詳細は、7章Java クライアントで Kafka シリアライザー/デシリアライザーを使用したスキーマの検証 を参照してください。
- 設定オプションの詳細は、「Apicurio Registry シリアライザー/デシリアライザーの設定プロパティー」 を参照してください。
Kafka コンバーターの設定
public class SerdeBasedConverter<S, T> extends SchemaResolverConfigurer<S, T> implements Converter, Closeable {
public static final String REGISTRY_CONVERTER_SERIALIZER_PARAM = "apicurio.registry.converter.serializer"; 1
public static final String REGISTRY_CONVERTER_DESERIALIZER_PARAM = "apicurio.registry.converter.deserializer"; 2関連情報
- 詳細は、SerdeBasedConverter Java class を参照してください。
さまざまなスキーマタイプの設定
さまざまなスキーマ技術に SerDe を設定する方法は、以下を参照してください。
