Flink入门(十三) 读RocketMQ-Flink消息

github已经有开源地址RocketMQ-Flinkjava 直接把代码复制到本身代码中 git 这里面我新建一个类 org.apache.rocketmq.flink.common.serialization.SimpleStringDeserializationSchemagithub package org.apache.rocketmq.flink.common.serializatio
相关文章
相关标签/搜索