Flink with Avro Confluent Kafka-Registry

一、前言

Kafka Schema-Registry

二、Flink with Avro Confluent Kafka-Registry 2.1、生成User.java 2.1.1、user.avsc 数据格式文件

{
 "namespace": "example.avro",
 "type": "record",
 "name": "User",
 "fields": [
     {"name": "id", "type": "int", "default": 0},
     {"name": "name",  "type": "string", "default": ""},
     {"name": "age", "type": "int", "default": 0}
 ]
 }

2.1.2、使用 avro-tools-1.7.7.jar 生成 User 对象

java -jar doc/avro-tools-1.7.7.jar compile schema src/main/resources/user.avsc 

2.2、向test-topic生成 avro confluent kafka-registry消息

具体见 Kafka Schema-Registry—2.2.2.1、KafkaProducer