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

[ISSUE #12] Support scan startup mode #54

Closed liyubin117 closed 1 year ago

liyubin117 commented 1 year ago

link to #12

support to define the scan startup mode like lastest, earliest, timestamp.

CREATE TABLE rocketmq_source4 (
  surname STRING
) WITH (
  'connector' = 'rocketmq',
  'topic' = 'test3',
  'scanStartupMode' = 'latest',
  'consumerGroup' = 'a1',
  'nameServerAddress' = 'ip:9876'
)