In new api, what's the way to pass parameters?

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

In new api, what's the way to pass parameters? #114

Open humkum opened 3 months ago

humkum commented 3 months ago

I found the parameters of RocketMQSource are all set null, did I ignore some logic? What's the way of RocketMQSource in new api to pass the parameters? like consumerGroup, topic, accessKey, secretKey, etc.

humkum commented 3 months ago

@lizhimins Could you plz help me with this question?