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

The example of DataSream connector api should change RocketMQSource to RocketMQSourceFunction in the document. #11

Closed mispower closed 2 years ago

mispower commented 2 years ago

The DataStream example need update. All parameters of the source instance and the sink instance are not math.

env.addSource(new _**RocketMQSource**_(new SimpleKeyValueDeserializationSchema("id", "address"), consumerProps))
            .name("rocketmq-source")
            .setParallelism(2)....
SteNicholas commented 2 years ago

@mispower , it's recommended to use the RocketMQSource for the new Source interace of Flink. Which RocketMQ source are you using?