Closed dcy652701 closed 1 year ago
@dcy652701 , thanks for the reportor of the problem in README.md. The RocketMQSource(KeyValueDeserializationSchema schema, Properties props)
should be RocketMQSourceFunction(KeyValueDeserializationSchema schema, Properties props)
. Do you have interest to update this?
You can give it to me if you want
The README guide told to use RocketMQSource(KeyValueDeserializationSchema schema, Properties props) for creating a source.But I can't find the constructor which has these two params. I can run on my IDEA