[ISSUE #230][RIP-58]RocketMQ Streams improvement

[ni-ze]

close #230

[ni-ze]

ref:https://github.com/apache/rocketmq/wiki/%5BRIP-58%5D-RocketMQ-Streams-improvement

[codecov-commenter]

Codecov Report

Merging #229 (0763b38) into main (bb7931f) will not change coverage.
The diff coverage is 0.00%.

@@           Coverage Diff            @@
##            main    #229      +/-   ##
========================================
  Coverage   0.00%   0.00%              
========================================
  Files        713      74     -639     
  Lines      35565    2116   -33449     
  Branches    5923     200    -5723     
========================================
+ Misses     35565    2116   -33449     

Impacted Files	Coverage Δ
...g/apache/rocketmq/streams/core/RocketMQStream.java	0.00% <0.00%> (ø)
.../apache/rocketmq/streams/core/common/Constant.java	0.00% <0.00%> (ø)
...streams/core/function/supplier/AddTagSupplier.java	0.00% <0.00%> (ø)
...eams/core/function/supplier/AggregateSupplier.java	0.00% <0.00%> (ø)
...streams/core/function/supplier/FilterSupplier.java	0.00% <0.00%> (ø)
...treams/core/function/supplier/ForeachSupplier.java	0.00% <0.00%> (ø)
...function/supplier/JoinWindowAggregateSupplier.java	0.00% <0.00%> (ø)
...eams/core/function/supplier/KeySelectSupplier.java	0.00% <0.00%> (ø)
.../streams/core/function/supplier/PrintSupplier.java	0.00% <0.00%> (ø)
...q/streams/core/function/supplier/SinkSupplier.java	0.00% <0.00%> (ø)
... and 666 more

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more