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

手順

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

   String registryUrl = "https://registry.example.com/api";
   Properties props = new Properties();
   props.putIfAbsent(AbstractKafkaSerDe.REGISTRY_URL_CONFIG_PARAM, registryUrl);

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

   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(AbstractKafkaSerializer.REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM, FindLatestIdStrategy.class.getName()); 3

   1

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

   2

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

   3

   スキーマのグローバル ID を検索する検索ストラテジー。