Closed francisoliverlee closed 3 years ago
https://github.com/apache/rocketmq-streams/blob/5dbcd1d33646624cb2b46ff2f6afb9352b33973a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java#L52-L68
https://github.com/apache/rocketmq-streams/blob/5dbcd1d33646624cb2b46ff2f6afb9352b33973a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java#L52-L68