confluent Kafka 应用

com\linkedin\metadata\kafka\config\KafkaConfig.java

  @Value("${KAFKA_SCHEMAREGISTRY_URL:http://localhost:8081}")
  private String kafkaSchemaRegistryUrl;
# 读取配置文件的路径，默认为http://localhost:8081

Kafka 中使用 Avro 序列化组件(三)：Confluent Schema Registry

KafkaEventProducerFactory.java

datahub-master\gms\factories\src\main\java\com\linkedin\common\factory\KafkaEventProducerFactory.java

序列化方式：AvroSerializer

kafka自定义消息序列化和反序列化方式

SchemaRegistryUrl （配置文件属性）
Schema Registry 为 Avro 和 Protobuf 等内置编码格式维护 Schema 文本
KafkaProperties.java (bean) -》KafkaProducer.java

SchemaRegistry
Kafka Schema Registry 原理
 Kafka Schema Registry 使用教程(JAVA)

如果没有 Schema Registry服务，自定义的schema需要在数据生产端和数据消费端都保存。Kafka Schema Registry 提供了 KafkaAvroSerializer 和 KafkaAvroDeserializer 两个类。有了 Schema Registry服务，数据生成方设置好Schema，会自动注册到 registry服务中，这样数据消费方就不需要保存schema，直接消费就可以。