第8章 Java クライアントでの Kafka シリアライザー/デシリアライザーの設定
この章では、プロデューサーおよびコンシューマー Java クライアントアプリケーションで Kafka シリアライザー/デシリアライザー (SerDes) を設定する方法について詳説します。
前提条件
8.1. クライアントアプリケーションの Service Registry シリアライザー/デシリアライザーの設定
このセクションの定数例を使用して、特定のクライアントシリアライザー/デシリアライザー (SerDes) サービスおよびスキーマ検索ストラテジーを直接クライアントアプリケーションに設定できます。または、ファイルまたはインスタンスで対応する Service Registry アプリケーションプロパティーを設定できます。
以下のセクションでは、一般的に使用される SerDes 定数および設定オプションの例を紹介します。
SerDes サービスの設定
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- Service Registry の必須の URL。
-
ID 処理を拡張することで、他の ID 形式をサポートし、その形式に Service Registry SerDes サービスとの互換性を持たせます。たとえば、ID 形式を
LongからIntegerに変更すると Confluent ID 形式がサポートされます。 -
Confluent ID の処理を簡素化します。
trueに設定すると、Integerがグローバル ID の検索に使用されます。この設定は、ID_HANDLERオプションと一緒に使用しないでください。
関連情報
- 設定オプションの詳細は、「Service Registry シリアライザー/デシリアライザー設定プロパティー」 を参照してください。
SerDes 検索ストラテジーの設定
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 メッセージの検証 を参照してください。
- 設定オプションの詳細は、「Service 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- Service Registry Kafka コンバーターと使用するために必要なシリアライザー。
- Service Registry Kafka コンバーターと使用するために必要なデシリアライザー。
関連情報
- 詳細は、SerdeBasedConverter Java クラス を参照してください。
さまざまなスキーマタイプの設定
さまざまなスキーマ技術に SerDes を設定する方法は、以下を参照してください。
