hi casel Flink RocketMQ connector 是由 RockeMQ 社区维护的， 对应的项目地址是: https://github.com/apache/rocketmq-flink 这个版本默认的消息是格式 DELIMIT 格式(默认消息是 String，按分隔符进行分割)， 只能指定消息的列分隔符.
best, feng On Fri, May 26, 2023 at 7:44 PM casel.chen <casel_c...@126.com> wrote: > 有没有Flink RocketMQ官方连接器? 需要自己开发吗？Flink生态组件网址（用户上传自己开发的连接器格式什么的）是什么？
