Hi, RocketMQ Community, I have a proposal to improve the RocketMQ Streams, In this proposal, fellow problems will be solved: 1. remove *ConfigurableComponent*, which is a storage component for stream task 2.support custom serialization/deserialization for source topic and sink topic 3.support generics for the processing expressions 4.unify source topic and shuffle topic with the same consumer instance. 5. other improvements to make the code more readable.
I have written the proposal, and you can see it by the link below: https://shimo.im/docs/25q5Mw5bpysQN2qD Chinese version: https://shimo.im/docs/m8AZVd71ojHDZpAb Please reply to this email if you have any suggestions. Your response would be highly appreciated.
