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

手順

1. Service Registry の URL でクライアントを設定します。

   以下に例を示します。

   String registryUrl_node1 = PropertiesUtil.property(clientProperties, "registry.url.node1",
       "https://my-cluster-service-registry-myproject.example.com/api");
   RegistryService service = RegistryClient.cached(registryUrl);

2. クライアントをシリアライザーサービスで設定し、Service Registry でスキーマを検索するようにストラテジーを設定します。

   以下に例を示します。

   String registryUrl_node1 = PropertiesUtil.property(clientProperties, "registry.url.node1",
       "https://my-cluster-service-registry-myproject.example.com/api");
   
       clientProperties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, property(clientProperties, CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, "my-cluster-kafka-bootstrap:9092"));
       clientProperties.put(AbstractKafkaSerDe.REGISTRY_URL_CONFIG_PARAM, registryUrl_node1); 1
       clientProperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); 2
       clientProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, AvroKafkaSerializer.class.getName()); 3
       clientProperties.put(AbstractKafkaSerializer.REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM, FindLatestIdStrategy.class.getName()); 4

   1

   Service Registry の URL。

   2

   Service Registry により提供されるメッセージ キー のシリアライザーサービス。

   3

   Service Registry により提供されるメッセージ 値 のシリアライザーサービス。

   4

   スキーマのグローバル ID を検索する検索ストラテジー。Service Registry のグローバル ID (アーティファクト ID およびスキーマバージョン) に対してメッセージのスキーマを照合します。