9.9. 在使用者客户端中使用 Service Registry 模式

步骤

1. 为客户端配置服务注册表的 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 deserializer 服务配置客户端。

   例如：

   Deserializer<LogInput> deserializer = new AvroKafkaDeserializer <> ( 1
       service,
       new DefaultAvroDatumProvider<LogInput>().setUseSpecificAvroReader(true)
   );
   Serde<LogInput> logSerde = Serdes.serdeFrom( 2
       new AvroKafkaSerializer<>(service),
       deserializer
   );
   KStream<String, LogInput> input = builder.stream( 3
       INPUT_TOPIC,
       Consumed.with(Serdes.String(), logSerde)
   );

   1

   Service Registry 提供的 deserializer 服务。

   2

   反序列化采用 Apache Avro JSON 格式。

   3

   从客户端消耗的主题值派生而来的反序列化的输入数据。