7.5. 使用 Kafka producer 客户端的 schema

此流程描述了如何配置使用 Java 编写的 Kafka producer 客户端,以使用 Service Registry 的 schema。

先决条件

  • 已安装 Service Registry
  • 该 schema 使用 Service Registry 注册

流程

  1. 使用 Service Registry 的 URL 配置客户端。例如:

    String registryUrl = "https://registry.example.com/apis/registry/v2";
    Properties props = new Properties();
    props.putIfAbsent(SerdeConfig.REGISTRY_URL, registryUrl);
  2. 使用序列化程序和策略配置客户端,以在 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 提供的消息键的序列化器。
    • 2.Service Registry 提供的消息值的序列化器。
    • 3.查找策略查找架构的全局 ID。