I like IStorage design, good to start. This is a good improvement for our streams architecture. If you need another shepherd, you could count me :-)
BTW, your design seems to not solve the exactly-once semantic in the streaming scenario, or say, we miss some detailed comments in the doc? 倪泽 <[email protected]> 于2022年2月9日周三 17:38写道： > Hi, RocketMQ Community, > > First of all, Happy Chinese New Year! > I want to start a RIP to replace mysql with RocketMQ as state store in > RocketMQ-streams. Base the RocketMQ storage, I will provide a exactly-once > supported and efficient state storage scheme. > > I have written my proposal and you can click on the link below： > > > https://docs.google.com/document/d/1gmwU4rC5wyG07R55jW5oN4GzxHSq8QoFNdoNL61xT0M/edit?usp=sharing > > Chinese version： > > https://shimo.im/docs/pjDRKHqtdQC9RWCg > > If you have any questions or suggestions, please reply to this email or > comment on the proposal. > > > Thanks > Nize > -- Best Regards :-)
