search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Implementation of Apache RocketMQ Flink Catalog #32

Closed ShannonDing closed 1 year ago

ShannonDing commented 2 years ago

题目名称：Apache RocketMQ Flink Catalog 实现 导师介绍：蒋晓峰，@SteNicholas, Apache RocketMQ & Kyuubi & ShardingSphere Committer。 导师邮箱：nicholasjiang@apache.org 题目难度：进阶 题目描述：支持 Apache RocketMQ Flink Catalog 1、学习Apache Flink Catalog 知识，详细了解 Flink RocketMQ Connector 原理、使用方式、参数含义等。 2、根据 Flink Catalog Public Interfaces 实现 RocketMQCatalog 3、在社区中提交 Issue，完成相关代码，review后被社区合并

li-xiao-shuang commented 2 years ago

I will solve it

SteNicholas commented 2 years ago

@li-xiao-shuang, thanks for your willing contribution for RocketMQ Catalog. Please go ahead to implement.

li-xiao-shuang commented 2 years ago

@li-xiao-shuang, thanks for your willing contribution for RocketMQ Catalog. Please go ahead to implement.

ok

ShannonDing commented 1 year ago

link #3

deemogsw commented 1 year ago 
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>schema-registry-client</artifactId>
        <version>${rocketmq.schema.registry.version}</version>
    </dependency>
    <rocketmq.schema.registry.version>0.0.4-SNAPSHOT</rocketmq.schema.registry.version>

snapshot can't achieve in maven repository. Could you please use release version. @ShannonDing @li-xiao-shuang