关注重点：confluent版本对timestamp等类型的支持基本是残的本次梳理相关处理流程，并尝试修复该问题

表征从Kafka里面拖出来的数据
传给parquet模块发送的数据類

说明：图中有两个类同名，于是自个给他们起了别名这样也方面说明。