Avro + Kafka Native API
- 比较繁琐
- 编译
Schema
- 依赖于
Avro
实现自定义的序列化器和反序列化器
- 编译
引入依赖
1 | <dependency> |
Schema
路径:src/main/resources/user.json
1 | { |
发送消息
1 | String schemaFilePath = BijectionProducer.class.getClassLoader().getResource("user.json").getPath(); |
消费消息
1 | String schemaFilePath = BijectionProducer.class.getClassLoader().getResource("user.json").getPath(); |