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
141 stars 89 forks source link

[Polish] Move example code to somewhere? #55

Open GOODBOY008 opened 2 years ago

GOODBOY008 commented 2 years ago
企业微信截图_16615710612163
lizhimins commented 1 year ago

The concept of SimpleConsumer is introduced in RocketMQ 5.0. The demo here is a 4. x consumer demonstration, which can be distinguished by renaming.

在 RocketMQ 5.0 中引入了 SimpleConsumer 的概念,这里是 4.x 版本的消费者演示,可以通过重命名来区分下。