7.5. 使用 Kafka producer 客户端的模式
这个步骤描述了如何将使用 Java 编写的 Kafka producer 客户端配置为使用 Service Registry 的 schema。
先决条件
- 已安装 Service Registry
- 模式在 Service Registry 中注册
流程
使用 Service Registry 的 URL 配置客户端。例如：
String registryUrl = "https://registry.example.com/apis/registry/v2"; Properties props = new Properties(); props.putIfAbsent(SerdeConfig.REGISTRY_URL, registryUrl);
使用 serializer 配置客户端，以及策略以在 Service Registry 中查找 schema。例如：
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.Service Registry 提供的 message 键的序列化器。
- 2.Service Registry 提供的 message 值的序列化器。
- 3.查找架构的全局 ID 的 lookup 策略。
