signed

QiShunwang

“诚信为本、客户至上”

【Kafka】Kafka 使用传统的 avro API 自定义序列化类和反序列化类

2020/8/19 22:27:49   来源:

在这里插入图片描述

1.概述

参考:https://www.jianshu.com/p/4f724c7c497d 做的自己的实验。

stock.avsc文件生成相应的实体类,请参考

2.项目结构

在这里插入图片描述

3.定义 schema 文件

定义 schema 文件,并编译 maven 工程生成实体类
schema 文件名称为:stock.avsc,内容如下:

{
    "namespace":