7.5. Kafka プロデューサークライアントからのスキーマの使用

手順

1. Apicurio Registry の URL を使用してクライアントを設定します。以下に例を示します。

   Copy to Clipboard Toggle word wrap

   String registryUrl = "https://registry.example.com/apis/registry/v2";
   Properties props = new Properties();
   props.putIfAbsent(SerdeConfig.REGISTRY_URL, registryUrl);

2. 設定するシリアライザーを使用してクライアントを設定し、Apicurio Registry でスキーマを検索する戦略を設定します。以下に例を示します。

   Copy to Clipboard Toggle word wrap

   props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, "my-cluster-kafka-bootstrap:9092");
   props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, AvroKafkaSerializer.class.getName()); 

   1

   
   props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, AvroKafkaSerializer.class.getName()); 

   2

   
   props.put(SerdeConfig.FIND_LATEST_ARTIFACT, Boolean.TRUE); 

   3
   • 1.Apicurio Registry により提供されるメッセージキーのシリアライザー。
   • 2.Apicurio Registry によって提供されるメッセージ値のシリアライザー。
   • 3.スキーマのグローバル ID を検索する検索ストラテジー。