整齐麦片
Flink中实现自定义反序列化消费Kafka中的二进制数据
1.简介kafka中的数据通常以二进制或者字符串存储，本文是针对kafka中的二进制数据，自定义反序列化类，利用flink读取消费，将二进制数据反序列成指定的实体类对象。2.代码实现2.1编写自定义反序列化类继承AbstractDeserializationSchema，重写deserializer方法package com.bigdata.deserializer;import com.bigdata.bean.User;import org.apache.flink.api.common.
他的归档
热门文章
