In new api, what's the way to pass parameters? #114
Description
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.