java kafka接收protobuf类型数据 记录

Author Avatar
没饲养员的猩猩 11月 03,2021
  • 在其它设备中阅读本文章

需要已知条件
1.kafka 生产者 key value序列化方式
KEY_SERIALIZER_CLASS_CONFIG
VALUE_SERIALIZER_CLASS_CONFIG
2.protobuf 描述文件
3.生产者数据序列化包装方法(根据此对ByteBuffer还原)
通过protobuf对象类的build将对象序列化成字节数组

消费者处理
1.根据生产者 key value序列化方式 反序列化消息数据
KEY_DESERIALIZER_CLASS_CONFIG
VALUE_DESERIALIZER_CLASS_CONFIG
2.根据protobuf 描述文件 生成对应语言的 protobuf对象类
3.根据生产者pb数据序列化包装方法 对数据还原 反序列化
生成的 protobuf对象类内包含parseFrom方法用于 将ByteBuffer 转换为原对象