SoC

---

题目一

名称

基于 Flink 实现 RocketMQ Sink Connector

项目产出要求

• 完成基于 FLIP-143: Unified Sink API 实现 RocketMQ Connector 的 DataStream Sink
• 完成基于 FLIP-143: Unified Sink API 实现 RocketMQ Connector 的 Table Sink

项目技术要求

• 熟练掌握 Apache RocketMQ
• 熟练掌握 Apache Flink

---

题目二

名称

实现RocketMQ与Dapr的集成

项目产出要求

• 完成基于RocketMQ的PubSub实现
• 完成binding的实现
• 完成Component的提交

项目技术要求

• 熟练掌握 Apache RocketMQ
• 熟练掌握 Dapr